We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 2e78049 commit d5edddaCopy full SHA for d5eddda
src/publisher/message-batch.ts
@@ -90,6 +90,12 @@ export class MessageBatch {
90
tracing.PubsubSpans.createPublishSchedulerSpan(message);
91
}
92
93
+ /**
94
+ * Ends the current batch, and returns the messages and callbacks we've queued up.
95
+ *
96
+ * @private
97
+ * @internal
98
+ */
99
end(): BatchResults {
100
this.messages.forEach(m => m.publishSchedulerSpan?.end());
101
return {
src/telemetry-tracing.ts
@@ -105,7 +105,6 @@ export function isEnabled(): OpenTelemetryLevel {
105
* or subscriber span, depending on the context.
106
*
107
* @private
108
- * @internal
109
*/
110
export interface MessageWithAttributes {
111
attributes?: Attributes | null | undefined;
0 commit comments