Javascript + WCF的响应式扩展的任何例子

Question

我理解Javascript示例背后的基础知识，但我很难理解这将如何与WCF一起工作。我的目标是启用COMET (HTTP Push)样式访问我的数据，但我不确定Rx是否是正确的技术。

我如何使用Javascript Rx扩展与WCF?

Answer 1

WCF是否支持HTTP Push?将任意回调转换为Rx Observable相当容易，我是这样做的(在Coffeescript中):

this.createRxCallback = () ->
  subj = new Rx.Subject()
  subj.callback = (params...) -> subj.OnNext(params)
  return subj

然后你可以接受任何需要回调的函数，就像Socket.io中的这个例子:

socket = new io.Socket {node_server_url}
socket.connect()
myCoolObservable = createRxCallback()
socket.on 'message', myCoolObservable.callback
myCoolObservable.Subscribe (x) ->
  console.log x

或者一个简单的例子:

clickObservable = createRxCallback()
document.addEventListener 'myButton', clickObservable.callback, true
clickObservable.Subscribe (x) ->
  console.log "Button was clicked!"