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
47
48
49

use std::sync::Arc;

use crate::{
	descriptor::ObjectDescriptor,
	exchange::ExchangeShared,
	object::{expose_contract::ObjectExposeContract, observe_contract::ObjectObserveContract},
};

//TODO: desired update frequency and other params

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

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

	pub fn build(self) -> ObjectObserveContract {
		let object_core = self.exchange_shared.object_acquire(&self.descriptor);
		ObjectObserveContract::new(object_core, self.exchange_shared.next_object_observe_contract_id())
	}
}

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

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

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

	pub fn build(self) -> ObjectExposeContract {
		let object_core = self.exchange_shared.object_acquire(&self.descriptor);
		ObjectExposeContract::new(object_core, self.exchange_shared.next_object_expose_contract_id(), self.capacity.unwrap_or(1))
	}
}