Rx

Question

이있는 각 이벤트에 대해 지연된 두 번째 후속 이벤트 생성 현재 반응 형 프레임 워크로 MIDI 메시지를 처리하려고합니다.

NoteOn 이벤트를 생성 할 때는 NoteOff 이벤트를 따라야합니다. 그렇다면 일정 시간이 지났을 때 각 노트 다음에 두 번째 이벤트를 보내는 가장 좋은 방법은 무엇일까요?

뭔가 같은 : NoteOn 및 NoteOff 메시지가 동일한 유형 MidiMessage의이다

//pseudo code 
var noteOnObservable = GetNoteOns(); 
var noteOffObservable = noteOnObservable.ForEach(e => new NoteOffMessage(e.MidiNote)) 
    .Delay(e => GetDelay(e)); 
var notes = noteOnObservable.Merge(noteOffObservable); 

.

Answer 1

당신이 그랬던 것처럼. 이상적으로는 noteOnObservable를 게시 할 것입니다 그래서 당신은 여러 구독을하지 않아도 :

var noteOnObservable = GetNoteOns().Publish().RefCount(); 
var noteOffObservable = noteOnObservable 
    .Select(e => new NoteOffMessage(e.MidiNote)) 
    .Delay(e => GetDelay(e)); 
var notes = noteOnObservable.Merge(noteOffObservable); 

당신은 어떤 종류의 GetDelay 수익률을 설명하지 않았다. TimeSpan을 반환하면 관찰 가능으로 변환해야합니다. 가능하면 GetDelay 그 작품. 그렇지 않다면 다음을 수행 할 수 있습니다.

var noteOnObservable = GetNoteOns().Publish().RefCount(); 
var noteOffObservable = noteOnObservable 
    .Select(e => new NoteOffMessage(e.MidiNote)) 
    .Delay(e => Observable.Timer(GetDelay(e))); 
var notes = noteOnObservable.Merge(noteOffObservable);