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

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

Overview

Materialized control for a TestSinks probe. The probe exposes elements only after explicit demand while terminal events remain observable.

Defined in:

movie/streams/testkit.cr

Constructors

• .new(default_timeout : Time::Span = TESTKIT_DEFAULT_TIMEOUT)

Instance Method Summary

• #await_demand : Nil

  Internal TestSink hook: blocks until one unit of demand is available.

• #cancel_from_runtime(error : Exception = StreamCancelledError.new("test subscriber runtime stopped")) : Nil

  Internal runtime hook used to release a probe blocked on demand or an unconsumed assertion event.

• #expect_complete(*, timeout : Time::Span = @default_timeout) : self
• #expect_error(type : E.class, *, timeout : Time::Span = @default_timeout) : E forall E
• #expect_error(*, timeout : Time::Span = @default_timeout) : Exception
• #expect_next(expected : T, *, timeout : Time::Span = @default_timeout) : self
• #expect_next(*, timeout : Time::Span = @default_timeout) : T
• #expect_no_message(duration : Time::Span = 100.milliseconds) : self
• #publish(event : StreamEvent(T)) : Nil

  Internal TestSink hook.

• #request(n : Int32) : self
• #request(n : UInt64) : self

Constructor Detail

Instance Method Detail