incoming$

const incomingFG$ = outgoing$
  .filter(isOkRequest)
  .filter(({ method }) => method === "find" || method === "get")
  .map(({ service, method, query, _namespace }) =>
    xs.create({
      start: listener => {
        socket.emit(`${service}::${method}`, query, (error, response) => {
          if (error) listener.error(error);
          listener.next({
            service,
            event: method === "find" ? "found" : "got",
            response,
            request: {
              service,
              method,
              query,
              _namespace
            }
          });
        });
      },
      stop: () => {}
    })
  )
  .flatten();