diff --git a/stream/mount.go b/stream/mount.go
index abd4500..c1f3147 100644
--- a/stream/mount.go
+++ b/stream/mount.go
@@ -272,8 +272,11 @@ func (m *Mount) handlePacket(packet packetizer.Packet) {
 		var err error
 		for _, l := range m.listeners {
 			if !l.HasStarted() {
-				//TODO: handle error too?
-				l.Start(m.keepBuffer)
+				if err = l.Start(m.keepBuffer); err != nil {
+					log.Printf("failed to write data to %s client: %s\n", l.Identifier(), err)
+					toRemove = append(toRemove, l.Identifier())
+					continue
+				}
 			}
 			if err = l.Write(packet); err != nil {
 				log.Printf("failed to write data to %s client: %s\n", l.Identifier(), err)