0

次のような F# コードがあります。

module O = Control.Observable
//...
use ss = serve' 4000
         |> O.subscribe
            (fun c -> use cs = RSS.items
                               |> O.subscribe (bytes >> c.SendAll) |> ignore)

どこ

serve'    : int -> IObservable<Socket>
c         : Socket
RSS.items : IObservable<XElement>
bytes     : XElement -> byte []
c.SendAll : byte [] -> unit
  • 失敗するcsまで保持する最も慣用的な方法は何ですか?c.SendAll
  • 失敗した場合にサブスクリプションが破棄されるObservable.subscribeUntilError(action)場所を定義することはできますか? actionそうでなければ、押し続けるaction限り実行されますか?IObservable
4

1 に答える 1

0

私はこれを思いついた：

let inline Δ<'a> = Unchecked.defaultof<'a>
let inline LOG x = printf "%A" x

module O = Observable
  let d = ref (Δ:IDisposable)
  let b x = try a x with e -> LOG e; let s = !d in if s <> Δ then s.Dispose()
  d := o |> O.subscribe b
  {
    new IDisposable with
      member x.Dispose() = let s = !d in if s <> Δ then d := Δ; s.Dispose()
  }

違いを実証するために、試してみてくださいmain！

使用subscribe:

use s = new Subject<int>()
use x = s |> O.subscribe (fun _ -> raise <| Exception ())
use y = s |> O.subscribe (printf "%i")
s.OnNext 20

アプリケーションがクラッシュします:

Unhandled Exception: System.Exception: Exception of type 'System.Exception' was thrown.
   at Microsoft.FSharp.Core.Operators.Raise[T](Exception exn)
   at Program.System.x@604-5.Invoke(Int32 _arg1) in C:\Eniox\Eniox.News.Google\Eniox.News.Google\Program.fs:line 60
   at Microsoft.FSharp.Control.CommonExtensions.SubscribeToObservable@1915.System-IObserver`1-OnNext(T value)
   at System.Reactive.Observer`1.OnNext(T value)
   at System.Reactive.Subjects.Subject`1.OnNext(T value)
   at Program.System.main(String[] args) in C:\Eniox\Eniox.News.Google\Eniox.News.Google\Program.fs:line 606

現在使用していsubscribeUEます：

use s = new Subject<int>()
use x = s |> O.subscribeUE (fun _ -> raise <| Exception ())
use y = s |> O.subscribe   (printf "%i")
s.OnNext 20

喜んでサブスクリプションを破棄xし、アプリケーションは問題なく実行を続け、正常に終了します! 出力: _ LOG = ignore

20

RX 2.0 のどこかに同等の機能が実際に存在するかどうかを知りたいのですが、このコンビネータは便利すぎて除外できません。

于 2012-08-02T03:31:22.020 に答える