alef 0.23.33

Opinionated polyglot binding generator for Rust libraries
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

	handle := {{ start_call }}
	if handle == nil {
		if err := lastError(); err != nil {
			return nil, err
		}
		return nil, fmt.Errorf("failed to start {{ method_snake }} stream")
	}
	ch := make(chan {{ item_type }})
	go func() {
		defer close(ch)
		defer C.{{ ffi_prefix }}_{{ type_snake }}_{{ method_snake }}_free(handle)
		for {
			chunkPtr := C.{{ ffi_prefix }}_{{ type_snake }}_{{ method_snake }}_next(handle)
			if chunkPtr == nil {
				// Null = clean end-of-stream (errno 0) or stream error (errno != 0).
				// In either case there are no more chunks; close the channel.
				return
			}
			jsonPtr := C.{{ ffi_prefix }}_{{ item_snake }}_to_json(chunkPtr)
			if jsonPtr == nil {
				C.{{ ffi_prefix }}_{{ item_snake }}_free(chunkPtr)
				return
			}
{% if item_is_sum_type %}
			chunk, unmarshalErr := Unmarshal{{ item_type }}([]byte(C.GoString(jsonPtr)))
{% else %}
			var chunk {{ item_type }}
			unmarshalErr := json.Unmarshal([]byte(C.GoString(jsonPtr)), &chunk)
{% endif %}
			C.{{ ffi_prefix }}_free_string(jsonPtr)
			C.{{ ffi_prefix }}_{{ item_snake }}_free(chunkPtr)
			if unmarshalErr != nil {
				return
			}
			ch <- chunk
		}
	}()
	return ch, nil
}