Method Process
Process(IObservable<string>)
Creates a new file, writes the string in the observable sequence to the file, and then closes the file.
public override IObservable<string> Process(IObservable<string> source)Parameters
sourceIObservable<string>The sequence containing the string to write to the file.
Returns
- IObservable<string>
An observable sequence that is identical to the
sourcesequence but where there is an additional side effect of writing the string to the file.