Struct StreamProbeClient 

pub struct StreamProbeClient { /* private fields */ }

Consumer wrapper shared by Runtime Driver and Execution Adapter tests.

Implementations

impl StreamProbeClient

pub fn new(handle: NativeStreamHandle<StreamProbe>) -> Self

pub fn from_dependencies( dependencies: &PluginDependencies, ) -> Result<Self, RuntimeFailure>

pub async fn open( &self, request: StreamProbeOpen, ) -> Result<Result<NativeStream<StreamProbe>, StreamProbeError>, RuntimeFailure>

Trait Implementations

impl Debug for StreamProbeClient

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.