Stream

# Basic Stream:

## Stream is same as Observable in Rx

### create a new stream 
#### never forgot to close a stream in dispose
```
var mStream = new StreamController();
```
with fixed type: 
```
var mStream = new StreamController<String>();
//else
StramController<String> mStream = new StreamController<String>();
//else
StreamController<String> mStream = new StreamController();
//Note: For fixed type Stream you need to provide type on transform handleData arguments
```
### add new value in stream
```
mStream.sink.add("Tareq");
//
mStream.add("Islam");
```
### Listen/Observe to Stream or Observable
```
mStream.listen(
(item) { print(item)},
onError: (err) => print(err);
);
```

### Transform Stream:
```
var mTransform== new StreamTransformer.fromHandlers(
   handleData: (String item , sink){
      if(item !="Tareq"){
        sink.add(item +" rakib");
      }else{
        sink.addError("item is not right");
      }
   },

 );
 ```

## Convert Future into Stream
```
Stream<String> stream = new Stream.fromFuture(getData());
  print("Created the stream");

  stream.listen((data) {
    print("DataReceived: "+data);
  }, onDone: () {
    print("Task Done");
  }, onError: (error) {
    print("Some Error");
  });
```

# There are two type of stream 
#### 1. Single Subscription Stream
only single subscriber available. {Default in Dart}
```
StreamController<String> streamController = new StreamController();
```
#### 2. Broadcast Stream
multiple subscriber available.
```
StreamController<String> streamController = new StreamController.broadcast();
```