gistfile1.cs

public void Consume(ConnectorRequest message)
{
    var context = ProcessMessageContext.Create();
    var request = ProcessRequest(message, context);
    var timeout = BusinessTimeout(message.Timeout, context);
    Observable.Amb(request, timeout).Subscribe(SendResponse(message));
}