gcp-pubsub 0.1.0

A surf-based Google Cloud Platform PubSub client
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

use crate::presenters::EncodedMessage;
use serde::Serialize;
use serde_derive::Deserialize;

#[derive(Deserialize, Serialize)]
pub struct PublishMessage {
  pub messages: Vec<EncodedMessage>,
}

impl PublishMessage {
  pub fn from<T: serde::Serialize>(data: &T) -> Self {
    Self {
      messages: vec![EncodedMessage::new(data)],
    }
  }
}