Skip to content

Commit f74e13c

Browse files
committed
refactor(effect): remove actor annotations
1 parent 0a16e1e commit f74e13c

1 file changed

Lines changed: 0 additions & 34 deletions

File tree

  • rivetkit-typescript/packages/effect/src

rivetkit-typescript/packages/effect/src/Actor.ts

Lines changed: 0 additions & 34 deletions
Original file line numberDiff line numberDiff line change
@@ -295,7 +295,6 @@ export interface Actor<
295295
readonly messages: ReadonlyArray<Messages>;
296296
readonly events: Events;
297297
readonly options: Options;
298-
readonly annotations: Context.Context<never>;
299298
readonly State: Context.Service<StateService<Name>, StateRef<State["Type"]>>;
300299
readonly Events: Context.Service<EventsService<Name>, EventPubSubMap<Events>>;
301300
readonly Messages: Context.Service<
@@ -331,15 +330,6 @@ export interface Actor<
331330
| Message.ServicesClient<Messages>
332331
| Registry
333332
>;
334-
335-
annotate<I, S>(
336-
tag: Context.Key<I, S>,
337-
value: S,
338-
): Actor<Name, State, Actions, Messages, Events>;
339-
340-
annotateMerge<I>(
341-
annotations: Context.Context<I>,
342-
): Actor<Name, State, Actions, Messages, Events>;
343333
}
344334

345335
/**
@@ -474,28 +464,6 @@ const Proto = {
474464
`Actor.client for ${self._tag} is not yet implemented. Client runtime wiring is pending.`,
475465
);
476466
},
477-
annotate(this: AnyWithProps, tag: Context.Key<any, any>, value: any) {
478-
return makeProto({
479-
_tag: this._tag,
480-
stateSchema: this.stateSchema,
481-
actions: this.actions,
482-
messages: this.messages,
483-
events: this.events,
484-
options: this.options,
485-
annotations: Context.add(this.annotations, tag, value),
486-
});
487-
},
488-
annotateMerge(this: AnyWithProps, annotations: Context.Context<any>) {
489-
return makeProto({
490-
_tag: this._tag,
491-
stateSchema: this.stateSchema,
492-
actions: this.actions,
493-
messages: this.messages,
494-
events: this.events,
495-
options: this.options,
496-
annotations: Context.merge(this.annotations, annotations),
497-
});
498-
},
499467
};
500468

501469
const makeProto = <
@@ -511,7 +479,6 @@ const makeProto = <
511479
readonly messages: ReadonlyArray<Messages>;
512480
readonly events: Events;
513481
readonly options: Options;
514-
readonly annotations: Context.Context<never>;
515482
}): Actor<Name, State, Actions, Messages, Events> => {
516483
const key = `@rivetkit/effect/Actor/${options._tag}`;
517484
const StateTag = Context.Service<StateService<Name>, StateRef<State["Type"]>>(
@@ -571,6 +538,5 @@ export const make = <
571538
messages: (options?.messages ?? []) as ReadonlyArray<Message.AnyWithProps>,
572539
events: (options?.events ?? {}) as EventSchemas,
573540
options: options?.options ?? {},
574-
annotations: Context.empty(),
575541
}) as any;
576542
};

0 commit comments

Comments
 (0)