RegisterPort

Trait RegisterPort 

Source
pub trait RegisterPort<'a, D>: Node + Clone
where D: Deploy<'a> + ?Sized,
{ // Required methods fn register(&self, external_port_id: ExternalPortId, port: Self::Port); fn as_bytes_bidi( &self, external_port_id: ExternalPortId, ) -> impl Future<Output = DynSourceSink<Result<BytesMut, Error>, Bytes, Error>> + 'a; fn as_bincode_bidi<InT, OutT>( &self, external_port_id: ExternalPortId, ) -> impl Future<Output = DynSourceSink<OutT, InT, Error>> + 'a where InT: Serialize + 'static, OutT: DeserializeOwned + 'static; fn as_bincode_sink<T>( &self, external_port_id: ExternalPortId, ) -> impl Future<Output = Pin<Box<dyn Sink<T, Error = Error>>>> + 'a where T: Serialize + 'static; fn as_bincode_source<T>( &self, external_port_id: ExternalPortId, ) -> impl Future<Output = Pin<Box<dyn Stream<Item = T>>>> + 'a where T: DeserializeOwned + 'static; }
Available on crate feature build only.

Required Methods§

Source

fn register(&self, external_port_id: ExternalPortId, port: Self::Port)

Source

fn as_bytes_bidi( &self, external_port_id: ExternalPortId, ) -> impl Future<Output = DynSourceSink<Result<BytesMut, Error>, Bytes, Error>> + 'a

Source

fn as_bincode_bidi<InT, OutT>( &self, external_port_id: ExternalPortId, ) -> impl Future<Output = DynSourceSink<OutT, InT, Error>> + 'a
where InT: Serialize + 'static, OutT: DeserializeOwned + 'static,

Source

fn as_bincode_sink<T>( &self, external_port_id: ExternalPortId, ) -> impl Future<Output = Pin<Box<dyn Sink<T, Error = Error>>>> + 'a
where T: Serialize + 'static,

Source

fn as_bincode_source<T>( &self, external_port_id: ExternalPortId, ) -> impl Future<Output = Pin<Box<dyn Stream<Item = T>>>> + 'a
where T: DeserializeOwned + 'static,

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors§

Source§

impl<'a> RegisterPort<'a, HydroDeploy> for DeployExternal

Available on crate feature deploy only.
Source§

impl<'a> RegisterPort<'a, DockerDeploy> for DockerDeployExternal

Available on crate features docker_deploy and deploy only.
Source§

impl<'a> RegisterPort<'a, DockerDeployEcs> for DockerDeployExternalEcs

Available on crate features ecs_deploy and deploy only.