import { ObservableLike } from '@dws/muster-observable'; import { NodeDefinition, StatelessGraphNode, StatelessNodeDefinition, StatelessNodeType } from '../../../types/graph'; export declare type StreamFactory = (request: NodeDefinition) => ObservableLike; export interface FromStreamMiddlewareNode extends StatelessGraphNode<'from-stream-middleware', FromStreamMiddlewareNodeProperties> { } export interface FromStreamMiddlewareNodeDefinition extends StatelessNodeDefinition<'from-stream-middleware', FromStreamMiddlewareNodeProperties> { } export interface FromStreamMiddlewareNodeProperties { streamFactory: StreamFactory; } export declare const FromStreamMiddlewareNodeType: StatelessNodeType<'from-stream-middleware', FromStreamMiddlewareNodeProperties>; export declare function fromStreamMiddleware(streamFactory: StreamFactory): FromStreamMiddlewareNodeDefinition;