How to use the most.filter function in most

function onerrorHandler(msg, fileName, lineno) {
  return Log$WonderLog.error(Log$WonderLog.buildErrorMessage("render worker error", "" + (String(msg) + ""), "", "", "fileName:" + (String(fileName) + ("\n        lineno:" + (String(lineno) + "")))));
}

function _createAndSetWorkerState(param) {
  StateRenderWorkerService$Wonderjs.setState(StateDataRenderWorker$Wonderjs.renderWorkerStateData, CreateStateRenderWorkerService$Wonderjs.createState(/* () */0));
  return /* () */0;
}

Most.drain(Most.concatMap((function (e) {
            return Most.mergeArray((_createAndSetWorkerState(/* () */0), WorkerJobMainService$Wonderjs.getRenderWorkerJobStreamArr(JSON.parse(e.data.pipelineJobs), JSON.parse(e.data.jobs), /* tuple */[
                              WorkerJobHandleSystem$Wonderjs.createWorkerJobHandleMap,
                              WorkerJobHandleSystem$Wonderjs.getWorkerJobHandle
                            ], StateDataRenderWorker$Wonderjs.renderWorkerStateData)));
          }), Most.filter((function (e) {
                return e.data.operateType === "SEND_JOB_DATA";
              }), Most.fromEvent("message", Curry._1(WorkerService$Wonderjs.getSelf, /* () */0)))));

export {
  onerrorHandler ,
  _createAndSetWorkerState ,
  
}
/*  Not a pure module */

export function TodoItem(sources: TodoItemSources): TodoItemSinks {
  const { dom, todo$ } = sources

  const { editing$, value$ } = edit(dom)

  const update$ =
    merge(
      map(toggleTodoCompletion, sampleWith(toggleCompleted(dom), todo$)),
      sampleWith(filter((x) => !x, editing$), sample(editTodoTitle, value$, todo$)),
    )

  const remove$ = map((todo) => todo.id, sampleWith(remove(dom), todo$))

  const model$ = combineObj({ todo$, editing$ })

  const view$ = map(view, model$)

  return { view$, update$, remove$ }
}

export function newTodoStream(dom: DomSource): Stream {
  const newItem = query(`.${todoAppStyles.newItemClass}`, dom);

  const keyDown$ = events('keydown', newItem);

  const enterKey$ = filter(isEnterKey, keyDown$);

  const filledItem$ = filter(isItemFilled, enterKey$);

  const trimmedValue$ = map(trimmedValue, filledItem$);

  return trimmedValue$;
}

function _createGetWorkerDataStream(flags, target) {
  return Most.filter((function (e) {
                return e.data.operateType === JobConfigUtils$Wonderjs.getOperateType(flags);
              }), Most.fromEvent("message", target));
}

export const select = curry2((actionType, stream) =>
  filter(({ type }) => type && type === actionType, stream))

export function LocalStorage(sinks: LocalStorageSinks): LocalStorageSources {
  const { localStorage$ } = sinks

  const localStorageEvent$: Stream =
    filter(isLocalStorageEvent, fromEvent('storage', window, true))

  const storage$: Stream =
    multicast(merge(
      constant(window.localStorage, tap(storageAction, localStorage$)),
      constant(window.localStorage, localStorageEvent$),
    ))

  drain(storage$)

  const getItem = createGetItem(storage$)
  const length = createLength(storage$)

  const localStorage: LocalStorageSource =
    {
      getItem,
      length,

export function newTodoStream(dom: DomSource): Stream {
  const newItem = query(`.${todoAppStyles.newItemClass}`, dom);

  const keyDown$ = events('keydown', newItem);

  const enterKey$ = filter(isEnterKey, keyDown$);

  const filledItem$ = filter(isItemFilled, enterKey$);

  const trimmedValue$ = map(trimmedValue, filledItem$);

  return trimmedValue$;
}

export function newTodo(dom: DomSource): Stream {
  const newItem = query(`.${todoAppStyles.newTodoClass}`, dom)

  const keyDown$ = events('keydown', newItem)

  const enterKey$ = filter(isEnterKey, keyDown$)

  const trimmedValue$ = map(trimmedValue, enterKey$)

  return trimmedValue$
}

const selectAction = curry((actionType, stream) =>
  filter(({ type }) => type && type === actionType, stream))