send_bincode_interleaved does not exist anymore?

[FHaggs]

Hi, I’m trying to work on some projects to learn this awesome framework. In a YouTube video I watched, the presenter uses a function called send_bincode_interleaved, but it seems that function has been removed. What should I use instead? I am very new to this project, this is the very simple code I am working on

pub fn first_ten_cluster<'a>(leader: &Process<'a, Leader>, workers: &Cluster<'a, Worker>) {
    // Delegate the work of processing the first ten integers to the workers in the cluster.
    let samples = leader
        .source_iter(q!(0..10)) // : Stream<i32, Process<Leader>, ...>
        .round_robin_bincode(workers); // : Stream<i32, Cluster<Worker>, ...>;

    // Process the samples in the workers and send the results back to the leader.
    let proceed_stream = samples
        .map(q!(|n| n * 2))
        .inspect(q!(|n| println!("Processed value from worker: {}", n))) // : Stream<i32, Cluster<Worker>, ...>
        .send_bincode_interleaved(leader); // : KeyedStream<ClusterId<Worker>, i32, Process<Leader>, ...>
        
    // Collect the results back in the leader process.
    let total_value = proceed_stream.reduce_commutative(q!(|acum, from_worker| {
        *acum = *acum + from_worker;
    }));

    unsafe {
        total_value.sample_every(q!(Duration::from_secs(1)))
    }.for_each(q!(|n| println!("Total accumulated value so far: {}", n)));

}

[MingweiSamuel]

Ah yes, @shadaj we'll need to update the video at some point, let me check what it is called now

[MingweiSamuel]

Was changed in http://github.com/hydro-project/hydro/pull/1975 to now be .send_bincode(&leader).values() which should hopefully be more intuitive. .send_bincode returns a "keyed" stream, and .values() keeps the values and discards the key information (cluster IDs).

Let us know if you have any other troubles!