Daniel Ponte
dea092d448
Closes #14 Reviewed-on: #102 Co-authored-by: Daniel Ponte <amigan@gmail.com> Co-committed-by: Daniel Ponte <amigan@gmail.com>
12 lines
219 B
Go
12 lines
219 B
Go
package server
|
|
|
|
import (
|
|
"context"
|
|
|
|
"dynatron.me/x/stillbox/pkg/calls"
|
|
)
|
|
|
|
func (s *Server) Ingest(ctx context.Context, call *calls.Call) error {
|
|
ctx = context.WithoutCancel(ctx)
|
|
return s.sinks.EmitCall(ctx, call)
|
|
}
|