Function GraphSerializer

devtool/src/graphSerializer.ts:291–312

(sources: GraphSerializerSources)

}

function GraphSerializer(sources: GraphSerializerSources): GraphSerializerSinks {
  let zapSpeed$ = sources.Settings.map(settings =>
    (sources.FromPanel as Stream<ZapSpeed>).startWith(settings.zapSpeed),
  ).flatten();

  let graph$ = sources.DebugSinks
    .filter(sinksAreXStream)
    .map(buildGraph);

  let serializedGraph$ = xs.combine(graph$, zapSpeed$)
    .map(setupZapping)
    .compose(makeObjectifyGraph(sources.id))
    .map(object => CircularJSON.stringify(object));

  let invalid$ = sources.DebugSinks
    .filter(x => !sinksAreXStream(x))
    .mapTo('');

  return {
    graph: xs.merge(serializedGraph$, invalid$),
  };
}

const panelMessage$ = xs.create<string>({
  start(listener: Listener<string>) {