RxJsは、内部のタイトルを説明するために

Question

少し疑似コードを下に通過せずにサブスクライブします。 これまでのところ、私はobservableを拡張しようとしましたが、私が行った場合、observable内の演算子をオーバーライドする必要があるように見えます。

ほとんどの場合、イベントにメタデータを提供したいと考えています。

これは外部的に使用するライブラリなのでmyObjectを渡したくないので、私は自分のコードベース内のobservablesを購読しますが、observableを連鎖することは外部で行われます。

誰でもこれを達成するためのアイデアはありますか？ただ必要な、すでに書き込まれている

const server$ = RxHttpServer(server) 

const api$ = server.filter((request) => request.url.startsWith('/api')); 

const apiEndpoint$ = api.map(() => ({ 
    status: 400, 
    body: 'this is an api endpoint', 
    headers: { 
    } 
})); 

// Inside my library, note the use of the response object that I don't have access to: 
apiEndpoint.subscribe((dataToSend) => response.write(dataToSend)) 

内部ロジックと、これらのオブジェクトの取り扱い：コンテキストについては

、 は、私は私が次の操作を行うことができます純粋にRxJs HTTPライブラリを作成しようとしていますその応答オブジェクトに返信します。

Answer 1

responseForヘルパーを使用してレスポンスメタデータを取得し、各HTTPリクエストごとに1つずつレスポンスSubjectの観測可能なものを返すことができます。ライブラリユーザーは、それをサブスクライブし、各応答サブジェクトにデータを書き込むことができます。図書館では、あなたが同じ応答のサブジェクトに登録して、完了したらそれをクライアントに送り返すことができます。何かが好きです：

// even better extending the Observable prototype 
// const apiEndpoint$ = api$.mapResponseFor(... 
const apiEndpoint$ = api$.map(responseFor({ 
    status: 400, 
    body: 'this is an api endpoint', 
    headers: {} 
})); 

apiEndpoint$.subscribe(response => { 
    response.next(data) 
    response.complete() 
})