Hello all!
I'm trying to read json objects from a named pipe. The pipe will be
filled intermittently by bash scripts. After the Decode() of the first
object, any more calls to Decode() will return EOF. This seems proper
since the script has completed, but once it errors with EOF, there doesn't
seem to be a way to read any more.
Is there a way to 'reset' the decoder so when another script writes to the
pipe it can process the next object, or should I be doing some pipe length
validation before trying to decode?
Current read code snippet is...
decoder := json.NewDecoder(fpipe)
for {
err := decoder.Decode(&msg)
if err != nil {
if err == io.EOF {
// how to reset this?
} else {
logger.Fatal(err)
}
} else {
// send out the msg
--
You received this message because you are subscribed to the Google Groups
"golang-nuts" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To view this discussion on the web visit
https://groups.google.com/d/msgid/golang-nuts/0846d26b-8cd3-4d1f-bebb-9972ea248c30n%40googlegroups.com.
