ofEvent

ofEvent

Creates a source which will emit only the given event. This means that if the given event is a Push event then the returned source will emit the value followed by an End event.

See Also

• ofEventScheduled

Signature - source.ts#L836

Copyfunction ofEvent(event: Throw | End): Source<never>
1
function ofEvent(event: Throw | End): Source<never>

Parameters

CopyThrow | End
1
Throw | End

Example Usage

Copyimport { ofEvent, Throw, pipe, subscribe } from '@microstream/core';

const source = ofEvent(Throw(new Error('ERROR!1!!1!')));
pipe(source, subscribe(console.log));
// End(Error(...))
1
import { ofEvent, Throw, pipe, subscribe } from '@microstream/core';
2
3
const source = ofEvent(Throw(new Error('ERROR!1!!1!')));
4
pipe(source, subscribe(console.log));
5
// End(Error(...))

See Also

• throwError

• empty

Copyfunction ofEvent<T>(event: Event<T>): Source<T>
1
function ofEvent<T>(event: Event<T>): Source<T>

Parameters

CopyEvent<T>
1
Event<T>

Example Usage

Copyimport { ofEvent, Push, pipe, subscribe } from '@microstream/core';

const source = ofEvent(Push(123));
pipe(source, subscribe(console.log));
// Push(123)
// End
1
import { ofEvent, Push, pipe, subscribe } from '@microstream/core';
2
3
const source = ofEvent(Push(123));
4
pipe(source, subscribe(console.log));
5
// Push(123)
6
// End