unwrap

Documentation

Index

• func Unwrap(msg substrate.Message) substrate.Message
• type AnnotatedMessage

Functions

func Unwrap

func Unwrap(msg substrate.Message) substrate.Message

Unwrap is a convenience function that unwraps a chain of annotated messages and returns the original one.

Types

type AnnotatedMessage

type AnnotatedMessage interface {
	substrate.Message
	Original() substrate.Message
}

AnnotatedMessage is an interface implemented by messages used by sink wrappers, in particular the synchronous sink adapter. This allows the backends to retrieve the original message the user sent when invoking user provided callbacks for example for getting partition keys.