hakuban 0.8.5

Data-object sharing library
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46

use std::sync::Arc;

use super::expose_contract::TagExposeContract;
use crate::{exchange::ExchangeShared, TagDescriptor, TagObserveContract};

//TODO: composition cost, desired update frequency

#[must_use = "Call build() at the end of the contract-build chain."]
pub struct TagObserveContractBuilder {
	exchange_shared: Arc<ExchangeShared>,
	descriptor: TagDescriptor,
}

impl TagObserveContractBuilder {
	pub(crate) fn new(exchange_shared: Arc<ExchangeShared>, descriptor: TagDescriptor) -> TagObserveContractBuilder {
		TagObserveContractBuilder { exchange_shared, descriptor }
	}

	pub fn build(self) -> TagObserveContract {
		let tag_core = self.exchange_shared.tag_acquire(&self.descriptor);
		TagObserveContract::new(tag_core, self.exchange_shared.next_tag_observe_contract_id())
	}
}

#[must_use = "Call build() at the end of the contract-build chain."]
pub struct TagExposeContractBuilder {
	exchange_shared: Arc<ExchangeShared>,
	descriptor: TagDescriptor,
	capacity: Option<u32>,
}

impl TagExposeContractBuilder {
	pub(crate) fn new(exchange_shared: Arc<ExchangeShared>, descriptor: TagDescriptor) -> TagExposeContractBuilder {
		TagExposeContractBuilder { exchange_shared, descriptor, capacity: None }
	}

	pub fn with_capacity(mut self, capacity: u32) -> TagExposeContractBuilder {
		self.capacity = Some(capacity);
		self
	}

	pub fn build(self) -> TagExposeContract {
		let tag_core = self.exchange_shared.tag_acquire(&self.descriptor);
		TagExposeContract::new(tag_core, self.exchange_shared.next_tag_expose_contract_id(), self.capacity.unwrap_or(1))
	}
}