import { ObservableLike, Subscription } from '@dws/muster-observable'; import { NodeDefinition, NodeState, StatefulGraphNode, StatefulNodeDefinition, StatefulNodeType } from '../../../types/graph'; import { SchedulerFactory } from './types'; export interface OnStreamEmissionNode extends StatefulGraphNode<'on-stream-emission', OnStreamEmissionNodeProperties, OnStreamEmissionState, OnStreamEmissionData> { } export interface OnStreamEmissionNodeDefinition extends StatefulNodeDefinition<'on-stream-emission', OnStreamEmissionNodeProperties, OnStreamEmissionState, OnStreamEmissionData> { } export interface OnStreamEmissionNodeProperties { factory: () => NodeDefinition; stream: ObservableLike; } export interface OnStreamEmissionState extends NodeState { currentValue: NodeDefinition; } export interface OnStreamEmissionData { streamSubscription: Subscription; } export declare const OnStreamEmissionNodeType: StatefulNodeType<'on-stream-emission', OnStreamEmissionNodeProperties, OnStreamEmissionState, OnStreamEmissionData>; export declare function onStreamEmission(stream: ObservableLike): SchedulerFactory; export declare function isOnStreamEmissionNodeDefinition(value: NodeDefinition): value is OnStreamEmissionNodeDefinition;