class Movie::Streams::Typed::TestPublisherProbe(T)

• Movie::Streams::Typed::TestPublisherProbe(T)
• Reference
• Object

Overview

Materialized control for a TestSources probe.

Defined in:

movie/streams/testkit.cr

Constructors

• .new(control : ManualSourceControl(T), default_timeout : Time::Span = TESTKIT_DEFAULT_TIMEOUT)

Instance Method Summary

• #offer(value : T) : QueueOfferResult
• #send_complete : self
• #send_error(error : Exception) : self
• #send_next(value : T, *, timeout : Time::Span = @default_timeout) : self
• #terminal? : Bool

Constructor Detail

Instance Method Detail