Каков наилучший способ передать поток

Question

Я попытался передать поток в качестве аргумента, но я не уверен, какой путь является «лучшим», поэтому хотел бы услышать ваше мнение/предложения по моему образцу кода

Я лично предпочитаю варианты три, но я видел, как это делается в другом месте.

Вариант 1 подходит для небольших потоков (и потоки с известным размером)

варианта 2_1 и 2_2 всегда будет оставить «Левша» в сомнении о том, кто несет ответственность за утилизацию/закрытия.

public interface ISomeStreamHandler 
{ 
    // Option 1 
    void HandleStream(byte[] streamBytes); 

    // Option 2 
    void HandleStream(Stream stream); 

    // Option 3 
    void HandleStream(Func<Stream> openStream); 
} 


public interface IStreamProducer 
{ 
    Stream GetStream(); 
} 



public class SomeTestClass 
{ 
    private readonly ISomeStreamHandler _streamHandler; 
    private readonly IStreamProducer _streamProducer; 

    public SomeTestClass(ISomeStreamHandler streamHandler, IStreamProducer streamProducer) 
    { 
     _streamHandler = streamHandler; 
     _streamProducer = streamProducer; 
    } 

    public void DoOption1() 
    { 
     var buffer = new byte[16 * 1024]; 
     using (var input = _streamProducer.GetStream()) 
     { 
      using (var ms = new MemoryStream()) 
      { 
       int read; 
       while ((read = input.Read(buffer, 0, buffer.Length)) > 0) 
       { 
        ms.Write(buffer, 0, read); 
       } 
       _streamHandler.HandleStream(ms.ToArray()); 
      } 
     } 
    } 

    public void DoOption2_1() 
    { 
     _streamHandler.HandleStream(_streamProducer.GetStream()); 
    } 

    public void DoOption2_2() 
    { 
     using (var stream = _streamProducer.GetStream()) 
     { 
      _streamHandler.HandleStream(stream);  
     } 
    } 


    public void DoOption3() 
    { 
     _streamHandler.HandleStream(_streamProducer.GetStream); 
    } 
} 

Answer 1

Вариант 2_2 - это стандартный способ решения проблемных ресурсов.

Ваш SomeTestClass экземпляр просит продюсера для потока - то SomeTestClassвладеет поток и отвечает за очистку.

Варианты 3 и 2_1 полагаются на другой объект для очистки ресурса, принадлежащего SomeTestClass, - это ожидание может не выполняться.

Вариант 1 - это копирование содержимого потока в другой поток - я не вижу никаких преимуществ при этом.

Answer 2

Pass вокруг IStream и есть где-либо поток берет свое начало реализации IDisposable. Ответственность за удаление потока лежит на объекте, который его создал.

Answer 3

Возможно, вы не понимаете этого, но пытаетесь реализовать схему проектирования трубопровода . В качестве отправной точки, рассмотреть вопрос о принятии взглянуть на:

• MSDN: Pipelines
• Steve's Blog: Pipeline Design Pattern
• (другие хорошие ссылки ??)

Что касается вашей реализации, я рекомендую вам идти с опцией # 2:

public interface IStreamHandler 
{ 
    void Process(Stream stream); 
} 

Что касается Возражать жизни, это мое убеждение, что:

• реализации должен быть последовательным в том, как он обрабатывает вызов Dispose
• Ваше решение будет более гибким, если IStreamHandler не позвонил Dispose (сейчас Вы можете обработчики цепи вместе так же, как вы бы в Unix труб)

НЕЗАВИСИМЫЕ РЕШЕНИЯ

Построение решения трубопровода может быть интересно, но это также стоит отметить, что есть существующие продукты на рынок:

• Yahoo: Pipes
• Microsoft: BizTalk
• IBM: Cast Iron
• StackOverflow: Alternatives to Yahoo Pipes

ДОПОЛНИТЕЛЬНЫЕ УКАЗАНИЯ

Существует проблема дизайна, связанная с вашем предложил Вариант 2:

void Process(Stream stream); 

В Unix Pipes вы можете цепь ряда приложений вместе взяв вывод одной программы и сделав ее входом другой. Если вы собираетесь построить аналогичное решение, используя Вариант 2, у вас возникнут проблемы, если вы используете несколько обработчиков и ваши данные. Stream только вперед (т. Е. stream.CanSeek=False).