test: close session on agent shutdown

Signed-off-by: Timo Glastra <timo@animo.id>

tests/transport/SubjectOutboundTransport.ts

@@ -1,7 +1,7 @@
 import type { SubjectMessage } from './SubjectInboundTransport'
 import type { OutboundPackage, OutboundTransport, Agent, Logger } from '@aries-framework/core'
 
-import { takeUntil, Subject } from 'rxjs'
+import { takeUntil, Subject, take } from 'rxjs'
 
 import { InjectionSymbols, AriesFrameworkError } from '@aries-framework/core'
 
@@ -45,6 +45,8 @@ export class SubjectOutboundTransport implements OutboundTransport {
     // Create a replySubject just for this session. Both ends will be able to close it,
     // mimicking a transport like http or websocket. Close session automatically when agent stops
     const replySubject = new Subject<SubjectMessage>()
+    this.agent.config.stop$.pipe(take(1)).subscribe(() => !replySubject.closed && replySubject.complete())
+
     replySubject.pipe(takeUntil(this.agent.config.stop$)).subscribe({
       next: async ({ message }: SubjectMessage) => {
         this.logger.test('Received message')