fixed Event renamed api, some compile warnings cleanup

Stream/Readable.swift

@@ -160,7 +160,7 @@ public extension Readable {
             self.context.execute {
                 if newValue && self._rimpl._flow == nil {
                     self._rimpl._flow = self.on(.readable).react {
-                        self.read()
+                        let _ = self.read()
                     }
                 } else if !newValue && self._rimpl._flow != nil {
                     self._rimpl._flow?()
@@ -239,7 +239,7 @@ public extension Readable where InChunk : Creatable & BufferProtocol {
         let readableOff = self.on(.readable).react {
             //if we are not paused this one whould be called automatically
             if self.paused {
-                self.read()
+                let _ = self.read()
             }
         }
 
@@ -318,15 +318,15 @@ public class RawReadableSpiTest : RawReadableSpi {
             }
 
             if self.data?.isEmpty ?? false {
-                self._push(nil)
+                let _ = self._push(nil)
                 self.data = nil
             }
         }
     }
 }
 
 func f() {
-    let aa = RawReadableSpi()
+    let _ = RawReadableSpi()
 }
 
 /*public class RawReadableTest: RawReadable {

Stream/ReadableEvents.swift

@@ -53,7 +53,7 @@ public struct ReadableEventGroup<E : Event, Payload> {
 }
 
 public extension ReadableEventEmitterProtocol {
-    public func on<E : Event>(_ groupedEvent: ReadableEventGroup<E, InChunk>) -> EventConveyor<E.Payload> {
+    public func on<E : Event>(_ groupedEvent: ReadableEventGroup<E, InChunk>) -> SignalStream<E.Payload> {
         return self.on(groupedEvent.event)
     }
 

Stream/Stream.swift

@@ -38,7 +38,7 @@ public protocol StreamEventEmitterProtocol : EventEmitter {
 }
 
 public extension StreamEventEmitterProtocol {
-    func on<E : Event>(_ groupedEvent: StreamEventGroup<E>) -> EventConveyor<E.Payload> {
+    func on<E : Event>(_ groupedEvent: StreamEventGroup<E>) -> SignalStream<E.Payload> {
         return self.on(groupedEvent.event)
     }
 

Stream/Writable.swift

@@ -128,7 +128,7 @@ public class WritableImpl<Spi: WritableSpiProtocol> : WritableEventEmitterProtoc
 
             let dataOff = r.on(.data).settle(in: self.context).react { chunk in
                 //maybe we should handle the future result??
-                self._write(data: chunk)
+                let _ = self._write(data: chunk)
             }
 
             let errorOff = r.on(.error).settle(in: self.context).react { e in
@@ -139,7 +139,7 @@ public class WritableImpl<Spi: WritableSpiProtocol> : WritableEventEmitterProtoc
             }
 
             let endOff:SafeTask? = !end ? nil : r.on(.end).settle(in: self.context).react {
-                self._end()
+                let _ = self._end()
             }
 
             self._pipe = PipeConnection(readable: r, dataOff: dataOff, errorOff:errorOff, endOff:endOff)

Stream/WritableEvents.swift

@@ -59,7 +59,7 @@ public struct WritableEventGroup<E : Event> {
 }
 
 public extension WritableEventEmitterProtocol {
-    public func on<E : Event>(_ groupedEvent: WritableEventGroup<E>) -> EventConveyor<E.Payload> {
+    public func on<E : Event>(_ groupedEvent: WritableEventGroup<E>) -> SignalStream<E.Payload> {
         return self.on(groupedEvent.event)
     }