fixed #1

.gitignore

@@ -11,6 +11,6 @@
 # Output of the go coverage tool, specifically when used with LiteIDE
 *.out
 
-example/node_modules
+test/node_modules
 package-lock.json
-example/example
+test/test

ipc.go

@@ -130,7 +130,11 @@ func (ipc IPC) Start() {
 	}()
 	for {
 		reader := bufio.NewReader(os.Stdin)
-		text, _ := reader.ReadString('\n')
+		text, err := reader.ReadString('\n')
+		if err != nil {
+			log.Println(err)
+			continue
+		}
 		if text != "" {
 			var payload payloadReceive
 			text = strings.TrimSuffix(text, "\n")
@@ -144,16 +148,21 @@ func (ipc IPC) Start() {
 				if payload.Event == "___EXIT___" {
 					os.Exit(0)
 				}
-				if payload.SR {
-					for _, handler := range ipc.receiveSendListerners[payload.Event] {
-						replyChannel := payload.Event + "___RC___"
-						handler(replyChannel, payload.Data)
-					}
-				} else {
-					for _, handler := range ipc.receiveListerners[payload.Event] {
-						handler(payload.Data)
+				// Run the handlers in a goroutine to prevent
+				// https://github.com/Akumzy/ipc/issues/1
+				go func() {
+
+					if payload.SR {
+						for _, handler := range ipc.receiveSendListerners[payload.Event] {
+							replyChannel := payload.Event + "___RC___"
+							handler(replyChannel, payload.Data)
+						}
+					} else {
+						for _, handler := range ipc.receiveListerners[payload.Event] {
+							handler(payload.Data)
+						}
 					}
-				}
+				}()
 			}
 
 		}

test/node.js

@@ -0,0 +1,25 @@
+const IPC = require('ipc-node-go')
+const ipc = new IPC('./test')
+ipc.init()
+
+ipc.on('log', console.log)
+// Log all error from stderr
+ipc.on('error', console.error)
+// ipc.on('ping', () => {
+//   console.log(new Date())
+// })
+
+//
+ipc.send('who', { name: 'Akuma Nodejs' })
+// send and receive and an acknowledgement
+
+// listen for event and reply to the channel
+ipc.onReceiveAnSend('hola', (channel, data) => {
+  console.log(data)
+  ipc.send(channel, 'cool thanks')
+})
+// setInterval(() => {
+//   ipc.sendAndReceive('yoo', 'Hello, how are you doing?', (err, d) => {
+//     err ? console.error(err) : console.log(d)
+//   })
+// }, 20000)