Cyclejs读取/写入websocket驱动程序？

Question

我是cyclejs的新手，我正在寻找websocket支持，除了从docs和一些0.1.2节点端npm包中只读websocket驱动程序外，我没有看到任何东西。

我应该创建自己的驱动程序还是缺少一些东西？

在此先感谢

Answer 1

此页面帮助您吗？

https://cycle.js.org/drivers.html

具体的示例代码中提到：

function WSDriver(/* no sinks */) { 
    return xs.create({ 
    start: listener => { 
     this.connection = new WebSocket('ws://localhost:4000'); 
     connection.onerror = (err) => { 
      listener.error(err) 
     } 
     connection.onmessage = (msg) => { 
     listener.next(msg) 
     } 
    }, 
    stop:() => { 
     this.connection.close(); 
    }, 
}); 
} 

如果添加一个接收器，这应该是一个读写的驱动程序。从他们的文档：

大多数驱动程序，如DOM驱动程序，接收器（用于描述写入）和返回源（用于读取）。但是，对于只写驱动程序和只读驱动程序，我们可能会有有效的情况。

例如，我们刚才看到的单线日志驱动程序是只写驱动程序。注意它是一个不返回任何流的函数，它只是消耗它接收到的接收器消息。

其他驱动程序只创建向main（）发出事件的源流，但不从main（）接收任何接收器。例如，这是一个只读的Web Socket驱动程序，起草如下：