Function service_incoming

c_glib/example/receive-network.c:116–157

}

static gboolean
service_incoming(GSocketService *service,
                 GSocketConnection *connection,
                 GObject *source_object,
                 gpointer user_data)
{
  GArrowGIOInputStream *input =
    garrow_gio_input_stream_new(g_io_stream_get_input_stream(G_IO_STREAM(connection)));
  GError *error = NULL;
  GArrowRecordBatchStreamReader *reader =
    garrow_record_batch_stream_reader_new(GARROW_INPUT_STREAM(input), &error);
  if (!reader) {
    g_print("failed to create reader: %s\n", error->message);
    g_error_free(error);
    g_object_unref(input);
    return FALSE;
  }

  while (TRUE) {
    GArrowRecordBatch *record_batch =
      garrow_record_batch_reader_read_next(GARROW_RECORD_BATCH_READER(reader), &error);
    if (error) {
      g_print("failed to read the next record batch: %s\n", error->message);
      g_error_free(error);
      g_object_unref(reader);
      g_object_unref(input);
      return EXIT_FAILURE;
    }

    if (!record_batch) {
      break;
    }

    print_record_batch(record_batch);
    g_object_unref(record_batch);
  }

  g_object_unref(reader);
  g_object_unref(input);

  return FALSE;
}

#ifdef G_OS_UNIX
typedef struct