outgoingMessages
    .ObserveOn(TaskPoolScheduler.Default)
    .Subscribe(message => {
            writer.WriteString(message.ToString() + "\r\n");
            writer.StoreAsync().AsTask().Wait();
            writer.FlushAsync().AsTask().Wait();
        });