Struct gstd::msg::CodecCreateProgramFuture

pub struct CodecCreateProgramFuture<T> {
    pub waiting_reply_to: MessageId,
    pub program_id: ActorId,
    /* private fields */
}

Same as CreateProgramFuture, but allows decoding the reply’s payload instead of receiving a byte vector.

Generic T type should implement the Decode trait.

Examples

The following example explicitly annotates variable types for demonstration purposes only. Usually, annotating them is unnecessary because they can be inferred automatically.

use gstd::{msg::CodecCreateProgramFuture, prelude::*, prog, ActorId};

#[derive(Decode)]
#[codec(crate = gstd::codec)]
struct InitReply {
    field: String,
}

#[gstd::async_main]
async fn main() {
    let future: CodecCreateProgramFuture<InitReply> =
        prog::create_program_bytes_for_reply_as(code_id, b"salt", b"PING", 0, 0)
            .expect("Unable to create a program");
    let (prog_id, reply): (ActorId, InitReply) = future.await.expect("Unable to get a reply");
    let field: String = reply.field;
}

Fields

waiting_reply_to: MessageId

A message identifier for an expected reply.

program_id: ActorId

An identifier of a newly created program.

Implementations

impl<D: Decode> CodecCreateProgramFuture<D>

pub fn up_to(self, duration: Option<u32>) -> Result<Self>

Postpone handling for a maximum amount of blocks that could be paid, that doesn’t exceed a given duration.

pub fn exactly(self, duration: Option<u32>) -> Result<Self>

Postpone handling for a given specific amount of blocks.

Trait Implementations

impl<D: Decode> FusedFuture for CodecCreateProgramFuture<D>

fn is_terminated(&self) -> bool

Returns true if the underlying future should no longer be polled.

impl<D: Decode> Future for CodecCreateProgramFuture<D>

type Output = Result<(ActorId, D), Error>

The type of value produced on completion.

fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output>

Attempt to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.