···

       
0
       
 
       

     

       
1
       
 
       
export const enum TalkbackKind {

     

       
2
       
 
       
  Pull = 0,

     

       
3
       
 
       
  Close = 1,

     

       
4
       
 
       
}

     

       
5
       
 
       


     

       
0
       
 
       

     

       
6
       
 
       
export type TalkbackFn = (signal: TalkbackKind) => void;

     

       
7
       
 
       
export type TeardownFn = () => void;

     

       
8
       
 
       


     
···

       
16
       
 
       
  tag: T;

     

       
17
       
 
       
}

     

       
18
       
 
       


     

       
0
       
 
       

     

       
19
       
 
       
export type Start<_T> = Tag<SignalKind.Start> & [TalkbackFn];

     

       
0
       
 
       

     

       
20
       
 
       
export type Push<T> = Tag<SignalKind.Push> & [T];

     

       
0
       
 
       

     

       
0
       
 
       

     

       
21
       
 
       
export type Signal<T> = Start<T> | Push<T> | SignalKind.End;

     

       
22
       
 
       


     

       
0
       
 
       

     

       
23
       
 
       
export type Sink<T> = (signal: Signal<T>) => void;

     

       
0
       
 
       

     

       
24
       
 
       
export type Source<T> = (sink: Sink<T>) => void;

     

       
0
       
 
       

     

       
25
       
 
       
export type Operator<In, Out> = (a: Source<In>) => Source<Out>;

     

       
26
       
 
       


     

       
27
       
 
       
export interface Subscription {

     

···

       
1
       
+
       
/** A talkback signal is used to tell a [Source] that either the [Sink] is ready for new values or that the stream should be cancelled */

     

       
2
       
 
       
export const enum TalkbackKind {

     

       
3
       
 
       
  Pull = 0,

     

       
4
       
 
       
  Close = 1,

     

       
5
       
 
       
}

     

       
6
       
 
       


     

       
7
       
+
       
/** A talkback callback is sent to the sink with the [Start] signal to communicate signals back to the source. */

     

       
8
       
 
       
export type TalkbackFn = (signal: TalkbackKind) => void;

     

       
9
       
 
       
export type TeardownFn = () => void;

     

       
10
       
 
       


     
···

       
18
       
 
       
  tag: T;

     

       
19
       
 
       
}

     

       
20
       
 
       


     

       
21
       
+
       
/** The start [Signal] is the first signal and carries a callback (talkback) so the sink can send signals to the source */

     

       
22
       
 
       
export type Start<_T> = Tag<SignalKind.Start> & [TalkbackFn];

     

       
23
       
+
       
/** The Push [Signal] carries new values to the sink, like in an event emitter */

     

       
24
       
 
       
export type Push<T> = Tag<SignalKind.Push> & [T];

     

       
25
       
+
       


     

       
26
       
+
       
/** A signal that communicates new events to a sink. */

     

       
27
       
 
       
export type Signal<T> = Start<T> | Push<T> | SignalKind.End;

     

       
28
       
 
       


     

       
29
       
+
       
/** A sink accepts new values from a [Source], like [Push], [Start], and an end signal. The [Start] is used to receive a callback to send talkback signals back to the source. */

     

       
30
       
 
       
export type Sink<T> = (signal: Signal<T>) => void;

     

       
31
       
+
       
/** A source is a function that accepts a [Sink] and then starts sending [Signal]s to it. */

     

       
32
       
 
       
export type Source<T> = (sink: Sink<T>) => void;

     

       
33
       
+
       
/** An operator transforms a [Source] and returns a new [Source], potentially with different timings or output types. */

     

       
34
       
 
       
export type Operator<In, Out> = (a: Source<In>) => Source<Out>;

     

       
35
       
 
       


     

       
36
       
 
       
export interface Subscription {