f recv = loop do
  a <- lift await
  e <- recv a
  case e of
    Left o -> emit o $> Nothing
    Right r -> pure (Just r)