jaybe/bowlingManager
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
Files
19f99989b809a60e543a7a7c7c41121ecdc26588
bowlingManager/mobile/coverage/html/lib/services/event_bus.dart.gcov.html
T
jaybe 107abc963f TDD 작성
2025-08-12 03:28:08 +09:00

583 lines
64 KiB
HTML
Raw Blame History

<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html lang="en">
<head>
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
<title>LCOV - lcov.info - lib/services/event_bus.dart</title>
<link rel="stylesheet" type="text/css" href="../../gcov.css">
</head>
<body>
<table width="100%" border=0 cellspacing=0 cellpadding=0>
<tr><td class="title">LCOV - code coverage report</td></tr>
<tr><td class="ruler"><img src="../../glass.png" width=3 height=3 alt=""></td></tr>
<tr>
<td width="100%">
<table cellpadding=1 border=0 width="100%">
<tr>
<td width="10%" class="headerItem">Current view:</td>
<td width="10%" class="headerValue"><a href="../../index.html" title="Click to go to top-level">top level</a> - <a href="index.html" title="Click to go to directory lib/services">lib/services</a> - event_bus.dart</td>
<td width="5%"></td>
<td width="5%"></td>
<td width="5%" class="headerCovTableHead">Coverage</td>
<td width="5%" class="headerCovTableHead" title="Covered + Uncovered code">Total</td>
<td width="5%" class="headerCovTableHead" title="Exercised code only">Hit</td>
</tr>
<tr>
<td class="headerItem">Test:</td>
<td class="headerValue">lcov.info</td>
<td></td>
<td class="headerItem">Lines:</td>
<td class="headerCovTableEntryMed">77.8&nbsp;%</td>
<td class="headerCovTableEntry">194</td>
<td class="headerCovTableEntry">151</td>
</tr>
<tr>
<td class="headerItem">Test Date:</td>
<td class="headerValue">2025-08-12 03:21:51</td>
<td></td>
<td class="headerItem">Functions:</td>
<td class="headerCovTableEntryHi">-</td>
<td class="headerCovTableEntry">0</td>
<td class="headerCovTableEntry">0</td>
</tr>
<tr><td><img src="../../glass.png" width=3 height=3 alt=""></td></tr>
</table>
</td>
</tr>
<tr><td class="ruler"><img src="../../glass.png" width=3 height=3 alt=""></td></tr>
</table>
<table cellpadding=0 cellspacing=0 border=0>
<tr>
<td><br></td>
</tr>
<tr>
<td>
<pre class="sourceHeading"> Line data Source code</pre>
<pre class="source">
<span id="L1"><span class="lineNum"> 1</span> : import 'dart:async';</span>
<span id="L2"><span class="lineNum"> 2</span> : import 'dart:developer' as developer;</span>
<span id="L3"><span class="lineNum"> 3</span> : import 'package:flutter/foundation.dart';</span>
<span id="L4"><span class="lineNum"> 4</span> : import 'package:lanebow/utils/test_utils.dart';</span>
<span id="L5"><span class="lineNum"> 5</span> : import 'package:lanebow/utils/test_config.dart';</span>
<span id="L6"><span class="lineNum"> 6</span> : </span>
<span id="L7"><span class="lineNum"> 7</span> : // 이벤트 클래스들 - 클래스 외부로 이동</span>
<span id="L8"><span class="lineNum"> 8</span> : class ClubChangedEvent {</span>
<span id="L9"><span class="lineNum"> 9</span> : final String clubId;</span>
<span id="L10"><span class="lineNum"> 10</span> : </span>
<span id="L11"><span class="lineNum"> 11</span> <span class="tlaGNC"> 4 : ClubChangedEvent(this.clubId);</span></span>
<span id="L12"><span class="lineNum"> 12</span> : </span>
<span id="L13"><span class="lineNum"> 13</span> <span class="tlaGNC"> 4 : @override</span></span>
<span id="L14"><span class="lineNum"> 14</span> <span class="tlaGNC"> 8 : String toString() =&gt; 'ClubChangedEvent(clubId: $clubId)';</span></span>
<span id="L15"><span class="lineNum"> 15</span> : </span>
<span id="L16"><span class="lineNum"> 16</span> <span class="tlaUNC"> 0 : @override</span></span>
<span id="L17"><span class="lineNum"> 17</span> : bool operator ==(Object other) {</span>
<span id="L18"><span class="lineNum"> 18</span> : if (identical(this, other)) return true;</span>
<span id="L19"><span class="lineNum"> 19</span> <span class="tlaUNC"> 0 : return other is ClubChangedEvent &amp;&amp; other.clubId == clubId;</span></span>
<span id="L20"><span class="lineNum"> 20</span> : }</span>
<span id="L21"><span class="lineNum"> 21</span> : </span>
<span id="L22"><span class="lineNum"> 22</span> <span class="tlaUNC"> 0 : @override</span></span>
<span id="L23"><span class="lineNum"> 23</span> <span class="tlaUNC"> 0 : int get hashCode =&gt; clubId.hashCode;</span></span>
<span id="L24"><span class="lineNum"> 24</span> : }</span>
<span id="L25"><span class="lineNum"> 25</span> : </span>
<span id="L26"><span class="lineNum"> 26</span> : class EventBus {</span>
<span id="L27"><span class="lineNum"> 27</span> : // 테스트 환경에서 사용할 별도의 인스턴스 맵</span>
<span id="L28"><span class="lineNum"> 28</span> <span class="tlaGNC"> 36 : static final Map&lt;String, EventBus&gt; _testInstances = {};</span></span>
<span id="L29"><span class="lineNum"> 29</span> : </span>
<span id="L30"><span class="lineNum"> 30</span> : // 기본 싱글톤 인스턴스</span>
<span id="L31"><span class="lineNum"> 31</span> <span class="tlaGNC"> 42 : static final EventBus _instance = EventBus._internal();</span></span>
<span id="L32"><span class="lineNum"> 32</span> : </span>
<span id="L33"><span class="lineNum"> 33</span> : // 테스트 ID를 저장하는 변수 (테스트 격리용)</span>
<span id="L34"><span class="lineNum"> 34</span> : static String? _currentTestId;</span>
<span id="L35"><span class="lineNum"> 35</span> : </span>
<span id="L36"><span class="lineNum"> 36</span> : // 테스트 환경 초기화 상태 추적</span>
<span id="L37"><span class="lineNum"> 37</span> : static bool _isTestEnvironmentReady = false;</span>
<span id="L38"><span class="lineNum"> 38</span> : </span>
<span id="L39"><span class="lineNum"> 39</span> : // 테스트 환경 초기화 관련 로깅</span>
<span id="L40"><span class="lineNum"> 40</span> <span class="tlaGNC"> 12 : static void _logTestEnvironmentInit() {</span></span>
<span id="L41"><span class="lineNum"> 41</span> : _isTestEnvironmentReady = true;</span>
<span id="L42"><span class="lineNum"> 42</span> : if (kDebugMode) {</span>
<span id="L43"><span class="lineNum"> 43</span> <span class="tlaGNC"> 24 : debugPrint('EventBus: 테스트 환경 초기화 완료');</span></span>
<span id="L44"><span class="lineNum"> 44</span> : }</span>
<span id="L45"><span class="lineNum"> 45</span> : }</span>
<span id="L46"><span class="lineNum"> 46</span> : </span>
<span id="L47"><span class="lineNum"> 47</span> : // 활성 구독 수 추적 (디버깅 및 메모리 누수 감지용)</span>
<span id="L48"><span class="lineNum"> 48</span> : static int _activeSubscriptionCount = 0;</span>
<span id="L49"><span class="lineNum"> 49</span> : </span>
<span id="L50"><span class="lineNum"> 50</span> : /// 현재 활성화된 테스트 인스턴스 수 반환</span>
<span id="L51"><span class="lineNum"> 51</span> <span class="tlaGNC"> 3 : static int get testInstanceCount =&gt; _testInstances.length;</span></span>
<span id="L52"><span class="lineNum"> 52</span> : </span>
<span id="L53"><span class="lineNum"> 53</span> : // 테스트 재시도 횟수 추적 및 관리</span>
<span id="L54"><span class="lineNum"> 54</span> : static int _testRetryCount = 0;</span>
<span id="L55"><span class="lineNum"> 55</span> : </span>
<span id="L56"><span class="lineNum"> 56</span> : // 테스트 재시도 횟수 가져오기</span>
<span id="L57"><span class="lineNum"> 57</span> <span class="tlaUNC"> 0 : static int get testRetryCount =&gt; _testRetryCount;</span></span>
<span id="L58"><span class="lineNum"> 58</span> : </span>
<span id="L59"><span class="lineNum"> 59</span> : // 테스트 재시도 횟수 증가</span>
<span id="L60"><span class="lineNum"> 60</span> <span class="tlaUNC"> 0 : static void incrementRetryCount() {</span></span>
<span id="L61"><span class="lineNum"> 61</span> <span class="tlaUNC"> 0 : _testRetryCount++;</span></span>
<span id="L62"><span class="lineNum"> 62</span> <span class="tlaUNC"> 0 : if (kDebugMode || TestConfig.instance.isVerboseLogging) {</span></span>
<span id="L63"><span class="lineNum"> 63</span> <span class="tlaUNC"> 0 : debugPrint('EventBus: 테스트 재시도 횟수 증가 - $_testRetryCount');</span></span>
<span id="L64"><span class="lineNum"> 64</span> : }</span>
<span id="L65"><span class="lineNum"> 65</span> : }</span>
<span id="L66"><span class="lineNum"> 66</span> : </span>
<span id="L67"><span class="lineNum"> 67</span> : // 활성 구독 수 접근 게터</span>
<span id="L68"><span class="lineNum"> 68</span> <span class="tlaGNC"> 2 : static int get activeSubscriptionCount =&gt; _activeSubscriptionCount;</span></span>
<span id="L69"><span class="lineNum"> 69</span> : </span>
<span id="L70"><span class="lineNum"> 70</span> : // 현재 테스트 ID 설정 메서드</span>
<span id="L71"><span class="lineNum"> 71</span> <span class="tlaGNC"> 12 : static void setCurrentTestId(String testId) {</span></span>
<span id="L72"><span class="lineNum"> 72</span> : // 테스트 설정 로드 확인 및 로깅</span>
<span id="L73"><span class="lineNum"> 73</span> <span class="tlaGNC"> 12 : final config = TestConfig.instance;</span></span>
<span id="L74"><span class="lineNum"> 74</span> <span class="tlaGNC"> 12 : if (config.isVerboseLogging) {</span></span>
<span id="L75"><span class="lineNum"> 75</span> <span class="tlaUNC"> 0 : debugPrint('EventBus: 테스트 설정 로드 - asyncTimeout=${config.asyncTimeout}ms, testDelay=${config.testDelay}ms');</span></span>
<span id="L76"><span class="lineNum"> 76</span> : }</span>
<span id="L77"><span class="lineNum"> 77</span> : // 이전 테스트 ID가 있으면 해당 인스턴스 정리</span>
<span id="L78"><span class="lineNum"> 78</span> <span class="tlaGNC"> 1 : if (_currentTestId != null &amp;&amp; _currentTestId != testId) {</span></span>
<span id="L79"><span class="lineNum"> 79</span> <span class="tlaGNC"> 2 : if (_testInstances.containsKey(_currentTestId!)) {</span></span>
<span id="L80"><span class="lineNum"> 80</span> : try {</span>
<span id="L81"><span class="lineNum"> 81</span> <span class="tlaGNC"> 3 : _testInstances[_currentTestId!]!.dispose();</span></span>
<span id="L82"><span class="lineNum"> 82</span> : } catch (e) {</span>
<span id="L83"><span class="lineNum"> 83</span> : if (kDebugMode) {</span>
<span id="L84"><span class="lineNum"> 84</span> <span class="tlaUNC"> 0 : debugPrint('EventBus: 이전 인스턴스 dispose 중 오류 - $e');</span></span>
<span id="L85"><span class="lineNum"> 85</span> : }</span>
<span id="L86"><span class="lineNum"> 86</span> : } finally {</span>
<span id="L87"><span class="lineNum"> 87</span> <span class="tlaGNC"> 2 : _testInstances.remove(_currentTestId!);</span></span>
<span id="L88"><span class="lineNum"> 88</span> : }</span>
<span id="L89"><span class="lineNum"> 89</span> : }</span>
<span id="L90"><span class="lineNum"> 90</span> : }</span>
<span id="L91"><span class="lineNum"> 91</span> : </span>
<span id="L92"><span class="lineNum"> 92</span> : // 새 테스트 ID 설정</span>
<span id="L93"><span class="lineNum"> 93</span> : _currentTestId = testId;</span>
<span id="L94"><span class="lineNum"> 94</span> : </span>
<span id="L95"><span class="lineNum"> 95</span> : // 새 테스트 ID에 대한 인스턴스가 없으면 생성</span>
<span id="L96"><span class="lineNum"> 96</span> <span class="tlaGNC"> 24 : if (!_testInstances.containsKey(testId)) {</span></span>
<span id="L97"><span class="lineNum"> 97</span> <span class="tlaGNC"> 36 : _testInstances[testId] = EventBus._internal();</span></span>
<span id="L98"><span class="lineNum"> 98</span> : } else {</span>
<span id="L99"><span class="lineNum"> 99</span> : // 이미 존재하는 인스턴스라도 초기화 수행</span>
<span id="L100"><span class="lineNum"> 100</span> <span class="tlaGNC"> 3 : _testInstances[testId]!.reset();</span></span>
<span id="L101"><span class="lineNum"> 101</span> : }</span>
<span id="L102"><span class="lineNum"> 102</span> : </span>
<span id="L103"><span class="lineNum"> 103</span> : // 테스트 환경 초기화 로깅</span>
<span id="L104"><span class="lineNum"> 104</span> <span class="tlaGNC"> 12 : _logTestEnvironmentInit();</span></span>
<span id="L105"><span class="lineNum"> 105</span> : </span>
<span id="L106"><span class="lineNum"> 106</span> : // 활성 구독 수 초기화</span>
<span id="L107"><span class="lineNum"> 107</span> : _activeSubscriptionCount = 0;</span>
<span id="L108"><span class="lineNum"> 108</span> : </span>
<span id="L109"><span class="lineNum"> 109</span> : // 테스트 재시도 횟수 초기화</span>
<span id="L110"><span class="lineNum"> 110</span> : _testRetryCount = 0;</span>
<span id="L111"><span class="lineNum"> 111</span> : </span>
<span id="L112"><span class="lineNum"> 112</span> : if (kDebugMode) {</span>
<span id="L113"><span class="lineNum"> 113</span> <span class="tlaGNC"> 36 : debugPrint('EventBus: 테스트 ID 설정됨 - $testId');</span></span>
<span id="L114"><span class="lineNum"> 114</span> <span class="tlaGNC"> 36 : developer.log('EventBus 메모리 상태: $_testInstances', name: 'EventBus');</span></span>
<span id="L115"><span class="lineNum"> 115</span> : }</span>
<span id="L116"><span class="lineNum"> 116</span> : }</span>
<span id="L117"><span class="lineNum"> 117</span> : </span>
<span id="L118"><span class="lineNum"> 118</span> : // 현재 테스트 ID 초기화 메서드</span>
<span id="L119"><span class="lineNum"> 119</span> <span class="tlaGNC"> 11 : static Future&lt;void&gt; tearDownTestEnvironment() async {</span></span>
<span id="L120"><span class="lineNum"> 120</span> <span class="tlaUNC"> 0 : if (kDebugMode || TestConfig.instance.isVerboseLogging) {</span></span>
<span id="L121"><span class="lineNum"> 121</span> <span class="tlaGNC"> 22 : debugPrint('EventBus: 테스트 환경 초기화 해제 시작');</span></span>
<span id="L122"><span class="lineNum"> 122</span> : }</span>
<span id="L123"><span class="lineNum"> 123</span> : </span>
<span id="L124"><span class="lineNum"> 124</span> : // 테스트 환경 해제 전 비동기 리소스 상태 로깅</span>
<span id="L125"><span class="lineNum"> 125</span> <span class="tlaGNC"> 11 : await _logAsyncResourceState('테스트 환경 해제 전');</span></span>
<span id="L126"><span class="lineNum"> 126</span> : </span>
<span id="L127"><span class="lineNum"> 127</span> : // 테스트 종료 전 남아있는 타이머가 완료될 시간 제공</span>
<span id="L128"><span class="lineNum"> 128</span> <span class="tlaGNC"> 11 : await _ensureAllTimersComplete();</span></span>
<span id="L129"><span class="lineNum"> 129</span> : </span>
<span id="L130"><span class="lineNum"> 130</span> : // 현재 테스트 ID에 해당하는 인스턴스가 있는 경우 먼저 dispose 호출</span>
<span id="L131"><span class="lineNum"> 131</span> <span class="tlaGNC"> 20 : if (_currentTestId != null &amp;&amp; _testInstances.containsKey(_currentTestId!)) {</span></span>
<span id="L132"><span class="lineNum"> 132</span> : try {</span>
<span id="L133"><span class="lineNum"> 133</span> <span class="tlaUNC"> 0 : if (kDebugMode || TestConfig.instance.isVerboseLogging) {</span></span>
<span id="L134"><span class="lineNum"> 134</span> <span class="tlaGNC"> 30 : debugPrint('EventBus: 현재 테스트 ID($_currentTestId) 인스턴스 dispose 시도');</span></span>
<span id="L135"><span class="lineNum"> 135</span> : }</span>
<span id="L136"><span class="lineNum"> 136</span> <span class="tlaGNC"> 30 : await _testInstances[_currentTestId!]!.dispose();</span></span>
<span id="L137"><span class="lineNum"> 137</span> : } catch (e) {</span>
<span id="L138"><span class="lineNum"> 138</span> : if (kDebugMode) {</span>
<span id="L139"><span class="lineNum"> 139</span> <span class="tlaUNC"> 0 : debugPrint('EventBus: 현재 테스트 인스턴스 dispose 중 오류 - $e');</span></span>
<span id="L140"><span class="lineNum"> 140</span> : }</span>
<span id="L141"><span class="lineNum"> 141</span> : }</span>
<span id="L142"><span class="lineNum"> 142</span> : }</span>
<span id="L143"><span class="lineNum"> 143</span> : </span>
<span id="L144"><span class="lineNum"> 144</span> : _currentTestId = null;</span>
<span id="L145"><span class="lineNum"> 145</span> : // 테스트 환경 초기화 해제 로깅</span>
<span id="L146"><span class="lineNum"> 146</span> : _isTestEnvironmentReady = false;</span>
<span id="L147"><span class="lineNum"> 147</span> : if (kDebugMode) {</span>
<span id="L148"><span class="lineNum"> 148</span> <span class="tlaGNC"> 22 : debugPrint('EventBus: 테스트 환경 초기화 해제');</span></span>
<span id="L149"><span class="lineNum"> 149</span> : }</span>
<span id="L150"><span class="lineNum"> 150</span> : _activeSubscriptionCount = 0;</span>
<span id="L151"><span class="lineNum"> 151</span> : </span>
<span id="L152"><span class="lineNum"> 152</span> : // 테스트 환경 해제 후 비동기 리소스 상태 로깅</span>
<span id="L153"><span class="lineNum"> 153</span> <span class="tlaGNC"> 11 : await _logAsyncResourceState('테스트 환경 해제 후');</span></span>
<span id="L154"><span class="lineNum"> 154</span> : </span>
<span id="L155"><span class="lineNum"> 155</span> : // 메모리 누수 방지를 위해 GC 힌트 추가</span>
<span id="L156"><span class="lineNum"> 156</span> <span class="tlaGNC"> 11 : if (TestUtils.isInTest) {</span></span>
<span id="L157"><span class="lineNum"> 157</span> <span class="tlaGNC"> 2 : developer.log('EventBus 메모리 정리 요청', name: 'EventBus');</span></span>
<span id="L158"><span class="lineNum"> 158</span> : }</span>
<span id="L159"><span class="lineNum"> 159</span> : </span>
<span id="L160"><span class="lineNum"> 160</span> : // 추가 마이크로태스크 실행으로 비동기 작업 완료 보장</span>
<span id="L161"><span class="lineNum"> 161</span> <span class="tlaGNC"> 22 : await Future.microtask(() {});</span></span>
<span id="L162"><span class="lineNum"> 162</span> <span class="tlaGNC"> 22 : await Future.microtask(() {});</span></span>
<span id="L163"><span class="lineNum"> 163</span> : }</span>
<span id="L164"><span class="lineNum"> 164</span> : </span>
<span id="L165"><span class="lineNum"> 165</span> : // 테스트 ID 초기화 (후방 호환성을 위해 유지)</span>
<span id="L166"><span class="lineNum"> 166</span> <span class="tlaGNC"> 10 : static Future&lt;void&gt; clearCurrentTestId() async {</span></span>
<span id="L167"><span class="lineNum"> 167</span> : // tearDownTestEnvironment로 대체되었지만 후방 호환성을 위해 유지</span>
<span id="L168"><span class="lineNum"> 168</span> <span class="tlaGNC"> 10 : await tearDownTestEnvironment();</span></span>
<span id="L169"><span class="lineNum"> 169</span> : }</span>
<span id="L170"><span class="lineNum"> 170</span> : </span>
<span id="L171"><span class="lineNum"> 171</span> : // 모든 테스트 인스턴스를 정리하는 정적 메서드</span>
<span id="L172"><span class="lineNum"> 172</span> <span class="tlaGNC"> 1 : static Future&lt;void&gt; resetAllTestInstances() async {</span></span>
<span id="L173"><span class="lineNum"> 173</span> <span class="tlaGNC"> 2 : if (_testInstances.isEmpty) {</span></span>
<span id="L174"><span class="lineNum"> 174</span> : return;</span>
<span id="L175"><span class="lineNum"> 175</span> : }</span>
<span id="L176"><span class="lineNum"> 176</span> : </span>
<span id="L177"><span class="lineNum"> 177</span> <span class="tlaUNC"> 0 : if (kDebugMode || TestConfig.instance.isVerboseLogging) {</span></span>
<span id="L178"><span class="lineNum"> 178</span> <span class="tlaGNC"> 5 : debugPrint('EventBus: 모든 테스트 인스턴스 초기화 시작 (인스턴스 수: ${_testInstances.length})');</span></span>
<span id="L179"><span class="lineNum"> 179</span> : }</span>
<span id="L180"><span class="lineNum"> 180</span> : </span>
<span id="L181"><span class="lineNum"> 181</span> : // 초기화 전 비동기 리소스 상태 로깅</span>
<span id="L182"><span class="lineNum"> 182</span> <span class="tlaGNC"> 1 : await _logAsyncResourceState('모든 테스트 인스턴스 초기화 전');</span></span>
<span id="L183"><span class="lineNum"> 183</span> : </span>
<span id="L184"><span class="lineNum"> 184</span> : // 기존 인스턴스 모두 정리</span>
<span id="L185"><span class="lineNum"> 185</span> <span class="tlaGNC"> 3 : for (var entry in _testInstances.entries) {</span></span>
<span id="L186"><span class="lineNum"> 186</span> : try {</span>
<span id="L187"><span class="lineNum"> 187</span> : if (kDebugMode) {</span>
<span id="L188"><span class="lineNum"> 188</span> <span class="tlaGNC"> 4 : debugPrint('EventBus: 인스턴스 정리 중 - ${entry.key}');</span></span>
<span id="L189"><span class="lineNum"> 189</span> : }</span>
<span id="L190"><span class="lineNum"> 190</span> <span class="tlaGNC"> 2 : entry.value.dispose(); // 완전히 dispose 호출</span></span>
<span id="L191"><span class="lineNum"> 191</span> : </span>
<span id="L192"><span class="lineNum"> 192</span> : // 각 인스턴스 dispose 후 마이크로태스크 실행으로 비동기 작업 완료 보장</span>
<span id="L193"><span class="lineNum"> 193</span> <span class="tlaGNC"> 2 : await Future.microtask(() {});</span></span>
<span id="L194"><span class="lineNum"> 194</span> : } catch (e) {</span>
<span id="L195"><span class="lineNum"> 195</span> : // dispose 중 오류 무시</span>
<span id="L196"><span class="lineNum"> 196</span> : if (kDebugMode) {</span>
<span id="L197"><span class="lineNum"> 197</span> <span class="tlaUNC"> 0 : debugPrint('EventBus: 인스턴스 정리 중 오류 - $e');</span></span>
<span id="L198"><span class="lineNum"> 198</span> : }</span>
<span id="L199"><span class="lineNum"> 199</span> : }</span>
<span id="L200"><span class="lineNum"> 200</span> : }</span>
<span id="L201"><span class="lineNum"> 201</span> : </span>
<span id="L202"><span class="lineNum"> 202</span> : // 인스턴스 정리 후 중간 상태 로깅</span>
<span id="L203"><span class="lineNum"> 203</span> <span class="tlaGNC"> 1 : await _logAsyncResourceState('테스트 인스턴스 dispose 후, 초기화 전');</span></span>
<span id="L204"><span class="lineNum"> 204</span> : </span>
<span id="L205"><span class="lineNum"> 205</span> : // 모든 테스트 인스턴스 제거</span>
<span id="L206"><span class="lineNum"> 206</span> <span class="tlaGNC"> 2 : _testInstances.clear();</span></span>
<span id="L207"><span class="lineNum"> 207</span> : </span>
<span id="L208"><span class="lineNum"> 208</span> : // 기본 인스턴스도 초기화</span>
<span id="L209"><span class="lineNum"> 209</span> : try {</span>
<span id="L210"><span class="lineNum"> 210</span> <span class="tlaGNC"> 2 : _instance.reset();</span></span>
<span id="L211"><span class="lineNum"> 211</span> <span class="tlaGNC"> 2 : await Future.microtask(() {}); // 기본 인스턴스 초기화 후 마이크로태스크 실행</span></span>
<span id="L212"><span class="lineNum"> 212</span> : } catch (e) {</span>
<span id="L213"><span class="lineNum"> 213</span> : // 기본 인스턴스 초기화 중 오류 무시</span>
<span id="L214"><span class="lineNum"> 214</span> : if (kDebugMode) {</span>
<span id="L215"><span class="lineNum"> 215</span> <span class="tlaUNC"> 0 : debugPrint('EventBus: 기본 인스턴스 초기화 중 오류 - $e');</span></span>
<span id="L216"><span class="lineNum"> 216</span> : }</span>
<span id="L217"><span class="lineNum"> 217</span> : }</span>
<span id="L218"><span class="lineNum"> 218</span> : </span>
<span id="L219"><span class="lineNum"> 219</span> : // 현재 테스트 ID도 초기화</span>
<span id="L220"><span class="lineNum"> 220</span> : _currentTestId = null;</span>
<span id="L221"><span class="lineNum"> 221</span> : // 테스트 환경 초기화 해제 로깅</span>
<span id="L222"><span class="lineNum"> 222</span> : if (_isTestEnvironmentReady) {</span>
<span id="L223"><span class="lineNum"> 223</span> : _isTestEnvironmentReady = false;</span>
<span id="L224"><span class="lineNum"> 224</span> : if (kDebugMode) {</span>
<span id="L225"><span class="lineNum"> 225</span> <span class="tlaGNC"> 2 : debugPrint('EventBus: 모든 테스트 환경 초기화 해제');</span></span>
<span id="L226"><span class="lineNum"> 226</span> : }</span>
<span id="L227"><span class="lineNum"> 227</span> : }</span>
<span id="L228"><span class="lineNum"> 228</span> : _activeSubscriptionCount = 0;</span>
<span id="L229"><span class="lineNum"> 229</span> : </span>
<span id="L230"><span class="lineNum"> 230</span> : // 비동기 작업이 완료될 시간을 제공하되, 타이머 생성 없이 동기화</span>
<span id="L231"><span class="lineNum"> 231</span> : // 타이머 생성 없이 마이크로태스크 큐 완료 보장</span>
<span id="L232"><span class="lineNum"> 232</span> <span class="tlaGNC"> 2 : await Future.microtask(() {});</span></span>
<span id="L233"><span class="lineNum"> 233</span> <span class="tlaGNC"> 2 : await Future.microtask(() {});</span></span>
<span id="L234"><span class="lineNum"> 234</span> : </span>
<span id="L235"><span class="lineNum"> 235</span> : // 테스트 종료 전 남아있는 타이머가 완료될 시간 제공</span>
<span id="L236"><span class="lineNum"> 236</span> : // 테스트 환경에서 !timersPending assertion 실패 방지</span>
<span id="L237"><span class="lineNum"> 237</span> <span class="tlaGNC"> 1 : await _ensureAllTimersComplete();</span></span>
<span id="L238"><span class="lineNum"> 238</span> : </span>
<span id="L239"><span class="lineNum"> 239</span> : // 초기화 완료 후 비동기 리소스 상태 로깅</span>
<span id="L240"><span class="lineNum"> 240</span> <span class="tlaGNC"> 1 : await _logAsyncResourceState('모든 테스트 인스턴스 초기화 후');</span></span>
<span id="L241"><span class="lineNum"> 241</span> : </span>
<span id="L242"><span class="lineNum"> 242</span> <span class="tlaUNC"> 0 : if (kDebugMode || TestConfig.instance.isVerboseLogging) {</span></span>
<span id="L243"><span class="lineNum"> 243</span> <span class="tlaGNC"> 2 : debugPrint('EventBus: 모든 테스트 인스턴스 초기화됨');</span></span>
<span id="L244"><span class="lineNum"> 244</span> <span class="tlaGNC"> 1 : developer.log('EventBus 메모리 상태 초기화 완료', name: 'EventBus');</span></span>
<span id="L245"><span class="lineNum"> 245</span> : }</span>
<span id="L246"><span class="lineNum"> 246</span> : }</span>
<span id="L247"><span class="lineNum"> 247</span> : </span>
<span id="L248"><span class="lineNum"> 248</span> : // 비동기 리소스 상태 진단 및 로깅</span>
<span id="L249"><span class="lineNum"> 249</span> <span class="tlaGNC"> 11 : static Future&lt;Map&lt;String, dynamic&gt;&gt; _diagnoseAsyncResources() async {</span></span>
<span id="L250"><span class="lineNum"> 250</span> <span class="tlaGNC"> 11 : final diagnosticInfo = &lt;String, dynamic&gt;{</span></span>
<span id="L251"><span class="lineNum"> 251</span> <span class="tlaGNC"> 22 : 'timestamp': DateTime.now().toIso8601String(),</span></span>
<span id="L252"><span class="lineNum"> 252</span> : 'activeSubscriptions': _activeSubscriptionCount,</span>
<span id="L253"><span class="lineNum"> 253</span> <span class="tlaGNC"> 22 : 'testInstances': _testInstances.length,</span></span>
<span id="L254"><span class="lineNum"> 254</span> : 'currentTestId': _currentTestId,</span>
<span id="L255"><span class="lineNum"> 255</span> : 'isTestEnvironmentReady': _isTestEnvironmentReady,</span>
<span id="L256"><span class="lineNum"> 256</span> : 'testRetryCount': _testRetryCount,</span>
<span id="L257"><span class="lineNum"> 257</span> : };</span>
<span id="L258"><span class="lineNum"> 258</span> : </span>
<span id="L259"><span class="lineNum"> 259</span> : // 인스턴스별 상태 수집</span>
<span id="L260"><span class="lineNum"> 260</span> <span class="tlaGNC"> 11 : final instanceStates = &lt;String, Map&lt;String, dynamic&gt;&gt;{};</span></span>
<span id="L261"><span class="lineNum"> 261</span> <span class="tlaGNC"> 33 : for (final entry in _testInstances.entries) {</span></span>
<span id="L262"><span class="lineNum"> 262</span> <span class="tlaGNC"> 33 : instanceStates[entry.key] = {</span></span>
<span id="L263"><span class="lineNum"> 263</span> <span class="tlaGNC"> 22 : 'isDisposed': entry.value._isDisposed,</span></span>
<span id="L264"><span class="lineNum"> 264</span> <span class="tlaGNC"> 33 : 'isStreamControllerClosed': entry.value._streamController.isClosed,</span></span>
<span id="L265"><span class="lineNum"> 265</span> : };</span>
<span id="L266"><span class="lineNum"> 266</span> : }</span>
<span id="L267"><span class="lineNum"> 267</span> <span class="tlaGNC"> 11 : diagnosticInfo['instanceStates'] = instanceStates;</span></span>
<span id="L268"><span class="lineNum"> 268</span> : </span>
<span id="L269"><span class="lineNum"> 269</span> : // 기본 인스턴스 상태</span>
<span id="L270"><span class="lineNum"> 270</span> <span class="tlaGNC"> 22 : diagnosticInfo['defaultInstance'] = {</span></span>
<span id="L271"><span class="lineNum"> 271</span> <span class="tlaGNC"> 22 : 'isDisposed': _instance._isDisposed,</span></span>
<span id="L272"><span class="lineNum"> 272</span> <span class="tlaGNC"> 33 : 'isStreamControllerClosed': _instance._streamController.isClosed,</span></span>
<span id="L273"><span class="lineNum"> 273</span> : };</span>
<span id="L274"><span class="lineNum"> 274</span> : </span>
<span id="L275"><span class="lineNum"> 275</span> : return diagnosticInfo;</span>
<span id="L276"><span class="lineNum"> 276</span> : }</span>
<span id="L277"><span class="lineNum"> 277</span> : </span>
<span id="L278"><span class="lineNum"> 278</span> : // 비동기 리소스 상태 로깅</span>
<span id="L279"><span class="lineNum"> 279</span> <span class="tlaGNC"> 11 : static Future&lt;void&gt; _logAsyncResourceState(String context) async {</span></span>
<span id="L280"><span class="lineNum"> 280</span> <span class="tlaUNC"> 0 : if (kDebugMode || TestConfig.instance.isVerboseLogging) {</span></span>
<span id="L281"><span class="lineNum"> 281</span> <span class="tlaGNC"> 11 : final diagnosticInfo = await _diagnoseAsyncResources();</span></span>
<span id="L282"><span class="lineNum"> 282</span> <span class="tlaGNC"> 33 : debugPrint('===== EventBus 비동기 리소스 상태 ($context) =====');</span></span>
<span id="L283"><span class="lineNum"> 283</span> <span class="tlaGNC"> 44 : debugPrint('시간: ${diagnosticInfo['timestamp']}');</span></span>
<span id="L284"><span class="lineNum"> 284</span> <span class="tlaGNC"> 44 : debugPrint('활성 구독 수: ${diagnosticInfo['activeSubscriptions']}');</span></span>
<span id="L285"><span class="lineNum"> 285</span> <span class="tlaGNC"> 44 : debugPrint('테스트 인스턴스 수: ${diagnosticInfo['testInstances']}');</span></span>
<span id="L286"><span class="lineNum"> 286</span> <span class="tlaGNC"> 44 : debugPrint('현재 테스트 ID: ${diagnosticInfo['currentTestId']}');</span></span>
<span id="L287"><span class="lineNum"> 287</span> <span class="tlaGNC"> 44 : debugPrint('테스트 환경 준비 상태: ${diagnosticInfo['isTestEnvironmentReady']}');</span></span>
<span id="L288"><span class="lineNum"> 288</span> <span class="tlaGNC"> 44 : debugPrint('테스트 재시도 횟수: ${diagnosticInfo['testRetryCount']}');</span></span>
<span id="L289"><span class="lineNum"> 289</span> : </span>
<span id="L290"><span class="lineNum"> 290</span> : // 인스턴스별 상태 출력</span>
<span id="L291"><span class="lineNum"> 291</span> <span class="tlaGNC"> 11 : final instanceStates = diagnosticInfo['instanceStates'] as Map&lt;String, Map&lt;String, dynamic&gt;&gt;;</span></span>
<span id="L292"><span class="lineNum"> 292</span> <span class="tlaGNC"> 11 : if (instanceStates.isNotEmpty) {</span></span>
<span id="L293"><span class="lineNum"> 293</span> <span class="tlaGNC"> 22 : debugPrint('--- 테스트 인스턴스 상태 ---');</span></span>
<span id="L294"><span class="lineNum"> 294</span> <span class="tlaGNC"> 22 : instanceStates.forEach((key, value) {</span></span>
<span id="L295"><span class="lineNum"> 295</span> <span class="tlaGNC"> 55 : debugPrint(' $key: disposed=${value['isDisposed']}, streamClosed=${value['isStreamControllerClosed']}');</span></span>
<span id="L296"><span class="lineNum"> 296</span> : });</span>
<span id="L297"><span class="lineNum"> 297</span> : }</span>
<span id="L298"><span class="lineNum"> 298</span> : </span>
<span id="L299"><span class="lineNum"> 299</span> : // 기본 인스턴스 상태</span>
<span id="L300"><span class="lineNum"> 300</span> <span class="tlaGNC"> 11 : final defaultInstance = diagnosticInfo['defaultInstance'] as Map&lt;String, dynamic&gt;;</span></span>
<span id="L301"><span class="lineNum"> 301</span> <span class="tlaGNC"> 22 : debugPrint('--- 기본 인스턴스 상태 ---');</span></span>
<span id="L302"><span class="lineNum"> 302</span> <span class="tlaGNC"> 55 : debugPrint(' disposed=${defaultInstance['isDisposed']}, streamClosed=${defaultInstance['isStreamControllerClosed']}');</span></span>
<span id="L303"><span class="lineNum"> 303</span> : </span>
<span id="L304"><span class="lineNum"> 304</span> <span class="tlaGNC"> 22 : debugPrint('===========================================');</span></span>
<span id="L305"><span class="lineNum"> 305</span> : }</span>
<span id="L306"><span class="lineNum"> 306</span> : }</span>
<span id="L307"><span class="lineNum"> 307</span> : </span>
<span id="L308"><span class="lineNum"> 308</span> <span class="tlaGNC"> 11 : static Future&lt;void&gt; _ensureAllTimersComplete() async {</span></span>
<span id="L309"><span class="lineNum"> 309</span> <span class="tlaUNC"> 0 : if (kDebugMode || TestConfig.instance.isVerboseLogging) {</span></span>
<span id="L310"><span class="lineNum"> 310</span> <span class="tlaGNC"> 22 : debugPrint('EventBus: 타이머 완료 대기 시작');</span></span>
<span id="L311"><span class="lineNum"> 311</span> : }</span>
<span id="L312"><span class="lineNum"> 312</span> : </span>
<span id="L313"><span class="lineNum"> 313</span> : // 비동기 리소스 상태 로깅 (시작)</span>
<span id="L314"><span class="lineNum"> 314</span> <span class="tlaGNC"> 11 : await _logAsyncResourceState('타이머 완료 대기 시작');</span></span>
<span id="L315"><span class="lineNum"> 315</span> : </span>
<span id="L316"><span class="lineNum"> 316</span> : // 타이머를 새로 만들지 않기 위해 microtask만 사용</span>
<span id="L317"><span class="lineNum"> 317</span> <span class="tlaGNC"> 22 : await Future.microtask(() {});</span></span>
<span id="L318"><span class="lineNum"> 318</span> <span class="tlaGNC"> 22 : await Future.microtask(() {});</span></span>
<span id="L319"><span class="lineNum"> 319</span> <span class="tlaGNC"> 22 : await Future.microtask(() {});</span></span>
<span id="L320"><span class="lineNum"> 320</span> : </span>
<span id="L321"><span class="lineNum"> 321</span> : // 중간 상태 로깅</span>
<span id="L322"><span class="lineNum"> 322</span> <span class="tlaGNC"> 11 : await _logAsyncResourceState('타이머 완료 중간 상태');</span></span>
<span id="L323"><span class="lineNum"> 323</span> : </span>
<span id="L324"><span class="lineNum"> 324</span> : // 테스트 설정에서 정의된 타이머 완료 대기 시간을 적용</span>
<span id="L325"><span class="lineNum"> 325</span> : // 추가 대기 시간이 설정되어 있어도 실제 Timer 생성은 하지 않음(테스트 타이머 경합 방지)</span>
<span id="L326"><span class="lineNum"> 326</span> : // 필요한 경우 호출자에서 fakeAsync 등을 사용해 제어하도록 위임</span>
<span id="L327"><span class="lineNum"> 327</span> : </span>
<span id="L328"><span class="lineNum"> 328</span> : // 비동기 리소스 상태 로깅 (완료)</span>
<span id="L329"><span class="lineNum"> 329</span> <span class="tlaGNC"> 11 : await _logAsyncResourceState('타이머 완료 대기 완료');</span></span>
<span id="L330"><span class="lineNum"> 330</span> : </span>
<span id="L331"><span class="lineNum"> 331</span> <span class="tlaUNC"> 0 : if (kDebugMode || TestConfig.instance.isVerboseLogging) {</span></span>
<span id="L332"><span class="lineNum"> 332</span> <span class="tlaGNC"> 22 : debugPrint('EventBus: 타이머 완료 대기 완료');</span></span>
<span id="L333"><span class="lineNum"> 333</span> : }</span>
<span id="L334"><span class="lineNum"> 334</span> : }</span>
<span id="L335"><span class="lineNum"> 335</span> : </span>
<span id="L336"><span class="lineNum"> 336</span> <span class="tlaGNC"> 11 : factory EventBus() {</span></span>
<span id="L337"><span class="lineNum"> 337</span> : // 테스트 환경에서는 테스트 ID 자동 생성 및 설정</span>
<span id="L338"><span class="lineNum"> 338</span> <span class="tlaGNC"> 11 : if (TestUtils.isInTest) {</span></span>
<span id="L339"><span class="lineNum"> 339</span> : // 테스트 ID가 설정되지 않았다면 자동으로 생성하지 말고, 명시적 설정을 강제한다</span>
<span id="L340"><span class="lineNum"> 340</span> : if (_currentTestId == null) {</span>
<span id="L341"><span class="lineNum"> 341</span> <span class="tlaUNC"> 0 : throw StateError('EventBus: 테스트 환경에서 currentTestId가 설정되지 않았습니다. setUp에서 EventBus.setCurrentTestId(...)를 호출하세요.');</span></span>
<span id="L342"><span class="lineNum"> 342</span> : }</span>
<span id="L343"><span class="lineNum"> 343</span> : </span>
<span id="L344"><span class="lineNum"> 344</span> : // 테스트 ID가 있지만 인스턴스가 없는 경우 생성</span>
<span id="L345"><span class="lineNum"> 345</span> <span class="tlaGNC"> 16 : if (!_testInstances.containsKey(_currentTestId!)) {</span></span>
<span id="L346"><span class="lineNum"> 346</span> : if (kDebugMode) {</span>
<span id="L347"><span class="lineNum"> 347</span> <span class="tlaUNC"> 0 : debugPrint('EventBus: 테스트 ID ${_currentTestId}에 대한 새 인스턴스 생성');</span></span>
<span id="L348"><span class="lineNum"> 348</span> : }</span>
<span id="L349"><span class="lineNum"> 349</span> <span class="tlaUNC"> 0 : _testInstances[_currentTestId!] = EventBus._internal();</span></span>
<span id="L350"><span class="lineNum"> 350</span> <span class="tlaUNC"> 0 : _testInstances[_currentTestId!]!.reset();</span></span>
<span id="L351"><span class="lineNum"> 351</span> : }</span>
<span id="L352"><span class="lineNum"> 352</span> : </span>
<span id="L353"><span class="lineNum"> 353</span> <span class="tlaGNC"> 16 : return _testInstances[_currentTestId]!;</span></span>
<span id="L354"><span class="lineNum"> 354</span> : }</span>
<span id="L355"><span class="lineNum"> 355</span> : </span>
<span id="L356"><span class="lineNum"> 356</span> : // 테스트 환경이 아닌 경우 기본 싱글톤 인스턴스 반환</span>
<span id="L357"><span class="lineNum"> 357</span> <span class="tlaGNC"> 3 : return _instance;</span></span>
<span id="L358"><span class="lineNum"> 358</span> : }</span>
<span id="L359"><span class="lineNum"> 359</span> : </span>
<span id="L360"><span class="lineNum"> 360</span> <span class="tlaGNC"> 15 : EventBus._internal();</span></span>
<span id="L361"><span class="lineNum"> 361</span> : </span>
<span id="L362"><span class="lineNum"> 362</span> : // 이벤트 버스 내부 상태</span>
<span id="L363"><span class="lineNum"> 363</span> : StreamController _streamController = StreamController.broadcast();</span>
<span id="L364"><span class="lineNum"> 364</span> : bool _isDisposed = false;</span>
<span id="L365"><span class="lineNum"> 365</span> : </span>
<span id="L366"><span class="lineNum"> 366</span> <span class="tlaGNC"> 12 : Stream get stream =&gt; _streamController.stream;</span></span>
<span id="L367"><span class="lineNum"> 367</span> : </span>
<span id="L368"><span class="lineNum"> 368</span> <span class="tlaGNC"> 4 : void fire(dynamic event) {</span></span>
<span id="L369"><span class="lineNum"> 369</span> <span class="tlaGNC"> 12 : if (!_isDisposed &amp;&amp; !_streamController.isClosed) {</span></span>
<span id="L370"><span class="lineNum"> 370</span> <span class="tlaGNC"> 8 : _streamController.add(event);</span></span>
<span id="L371"><span class="lineNum"> 371</span> : // 디버그 모드 또는 상세 로깅 설정 시 이벤트 발생 로그 추가</span>
<span id="L372"><span class="lineNum"> 372</span> <span class="tlaUNC"> 0 : if (kDebugMode || TestConfig.instance.isVerboseLogging) {</span></span>
<span id="L373"><span class="lineNum"> 373</span> <span class="tlaGNC"> 12 : debugPrint('EventBus: 이벤트 발생 - $event');</span></span>
<span id="L374"><span class="lineNum"> 374</span> : }</span>
<span id="L375"><span class="lineNum"> 375</span> <span class="tlaUNC"> 0 : } else if (kDebugMode || TestConfig.instance.isVerboseLogging) {</span></span>
<span id="L376"><span class="lineNum"> 376</span> <span class="tlaUNC"> 0 : debugPrint('EventBus: 이벤트 발생 실패 (이미 dispose됨) - $event');</span></span>
<span id="L377"><span class="lineNum"> 377</span> : }</span>
<span id="L378"><span class="lineNum"> 378</span> : }</span>
<span id="L379"><span class="lineNum"> 379</span> : </span>
<span id="L380"><span class="lineNum"> 380</span> : // 특정 타입의 이벤트를 구독하는 메서드</span>
<span id="L381"><span class="lineNum"> 381</span> <span class="tlaGNC"> 4 : Stream&lt;T&gt; on&lt;T&gt;() {</span></span>
<span id="L382"><span class="lineNum"> 382</span> <span class="tlaGNC"> 4 : if (_isDisposed) {</span></span>
<span id="L383"><span class="lineNum"> 383</span> <span class="tlaUNC"> 0 : if (kDebugMode || TestConfig.instance.isVerboseLogging) {</span></span>
<span id="L384"><span class="lineNum"> 384</span> <span class="tlaUNC"> 0 : debugPrint('EventBus: dispose된 인스턴스에서 on&lt;$T&gt; 호출됨');</span></span>
<span id="L385"><span class="lineNum"> 385</span> : }</span>
<span id="L386"><span class="lineNum"> 386</span> : // 빈 스트림 반환</span>
<span id="L387"><span class="lineNum"> 387</span> <span class="tlaUNC"> 0 : return Stream&lt;T&gt;.empty();</span></span>
<span id="L388"><span class="lineNum"> 388</span> : }</span>
<span id="L389"><span class="lineNum"> 389</span> : </span>
<span id="L390"><span class="lineNum"> 390</span> : // 타입 필터링 및 변환</span>
<span id="L391"><span class="lineNum"> 391</span> <span class="tlaGNC"> 20 : final filteredStream = stream.where((event) =&gt; event is T).cast&lt;T&gt;();</span></span>
<span id="L392"><span class="lineNum"> 392</span> : </span>
<span id="L393"><span class="lineNum"> 393</span> : // 구독 생성 시 카운터 증가 - 한 번만 증가</span>
<span id="L394"><span class="lineNum"> 394</span> <span class="tlaGNC"> 4 : _activeSubscriptionCount++;</span></span>
<span id="L395"><span class="lineNum"> 395</span> : </span>
<span id="L396"><span class="lineNum"> 396</span> <span class="tlaGNC"> 4 : if (TestUtils.isInTest) {</span></span>
<span id="L397"><span class="lineNum"> 397</span> <span class="tlaUNC"> 0 : if (kDebugMode || TestConfig.instance.isVerboseLogging) {</span></span>
<span id="L398"><span class="lineNum"> 398</span> <span class="tlaGNC"> 12 : debugPrint('EventBus: 새 구독 추가됨 &lt;$T&gt; (현재 구독 수: $_activeSubscriptionCount)');</span></span>
<span id="L399"><span class="lineNum"> 399</span> : }</span>
<span id="L400"><span class="lineNum"> 400</span> : </span>
<span id="L401"><span class="lineNum"> 401</span> : // 구독 취소 시 카운터 감소를 위한 처리</span>
<span id="L402"><span class="lineNum"> 402</span> : // StreamController를 사용하여 구독 취소 시 카운터 감소 보장</span>
<span id="L403"><span class="lineNum"> 403</span> <span class="tlaGNC"> 4 : final controller = StreamController&lt;T&gt;();</span></span>
<span id="L404"><span class="lineNum"> 404</span> : </span>
<span id="L405"><span class="lineNum"> 405</span> : // 원본 스트림에서 데이터 수신 및 전달</span>
<span id="L406"><span class="lineNum"> 406</span> <span class="tlaGNC"> 4 : final subscription = filteredStream.listen(</span></span>
<span id="L407"><span class="lineNum"> 407</span> <span class="tlaGNC"> 8 : (data) =&gt; controller.add(data),</span></span>
<span id="L408"><span class="lineNum"> 408</span> <span class="tlaUNC"> 0 : onError: (error) =&gt; controller.addError(error),</span></span>
<span id="L409"><span class="lineNum"> 409</span> <span class="tlaGNC"> 2 : onDone: () =&gt; controller.close(),</span></span>
<span id="L410"><span class="lineNum"> 410</span> : );</span>
<span id="L411"><span class="lineNum"> 411</span> : </span>
<span id="L412"><span class="lineNum"> 412</span> : // 컨트롤러 닫힐 때 구독 취소 및 카운터 감소</span>
<span id="L413"><span class="lineNum"> 413</span> <span class="tlaGNC"> 8 : controller.onCancel = () {</span></span>
<span id="L414"><span class="lineNum"> 414</span> <span class="tlaGNC"> 4 : subscription.cancel();</span></span>
<span id="L415"><span class="lineNum"> 415</span> <span class="tlaGNC"> 8 : _activeSubscriptionCount = (_activeSubscriptionCount &gt; 0) ? _activeSubscriptionCount - 1 : 0;</span></span>
<span id="L416"><span class="lineNum"> 416</span> <span class="tlaUNC"> 0 : if (kDebugMode || TestConfig.instance.isVerboseLogging) {</span></span>
<span id="L417"><span class="lineNum"> 417</span> <span class="tlaGNC"> 12 : debugPrint('EventBus: 구독 취소됨 &lt;$T&gt; (남은 구독 수: $_activeSubscriptionCount)');</span></span>
<span id="L418"><span class="lineNum"> 418</span> : }</span>
<span id="L419"><span class="lineNum"> 419</span> : };</span>
<span id="L420"><span class="lineNum"> 420</span> : </span>
<span id="L421"><span class="lineNum"> 421</span> <span class="tlaGNC"> 4 : return controller.stream;</span></span>
<span id="L422"><span class="lineNum"> 422</span> : }</span>
<span id="L423"><span class="lineNum"> 423</span> : </span>
<span id="L424"><span class="lineNum"> 424</span> : return filteredStream;</span>
<span id="L425"><span class="lineNum"> 425</span> : }</span>
<span id="L426"><span class="lineNum"> 426</span> : </span>
<span id="L427"><span class="lineNum"> 427</span> <span class="tlaGNC"> 15 : Future&lt;void&gt; _logInstanceState() async {</span></span>
<span id="L428"><span class="lineNum"> 428</span> <span class="tlaUNC"> 0 : if (kDebugMode || TestConfig.instance.isVerboseLogging) {</span></span>
<span id="L429"><span class="lineNum"> 429</span> <span class="tlaGNC"> 30 : debugPrint('EventBus 인스턴스 상태:');</span></span>
<span id="L430"><span class="lineNum"> 430</span> <span class="tlaGNC"> 60 : debugPrint(' isDisposed: $_isDisposed');</span></span>
<span id="L431"><span class="lineNum"> 431</span> <span class="tlaGNC"> 75 : debugPrint(' streamController.isClosed: ${_streamController.isClosed}');</span></span>
<span id="L432"><span class="lineNum"> 432</span> <span class="tlaGNC"> 15 : if (TestUtils.isInTest) {</span></span>
<span id="L433"><span class="lineNum"> 433</span> <span class="tlaGNC"> 21 : debugPrint(' 현재 테스트 ID: $_currentTestId');</span></span>
<span id="L434"><span class="lineNum"> 434</span> <span class="tlaGNC"> 21 : debugPrint(' 활성 구독 수: $_activeSubscriptionCount');</span></span>
<span id="L435"><span class="lineNum"> 435</span> : }</span>
<span id="L436"><span class="lineNum"> 436</span> : }</span>
<span id="L437"><span class="lineNum"> 437</span> : }</span>
<span id="L438"><span class="lineNum"> 438</span> : </span>
<span id="L439"><span class="lineNum"> 439</span> <span class="tlaGNC"> 15 : Future&lt;void&gt; dispose() async {</span></span>
<span id="L440"><span class="lineNum"> 440</span> <span class="tlaGNC"> 15 : if (!_isDisposed) {</span></span>
<span id="L441"><span class="lineNum"> 441</span> : // dispose 전 상태 로깅</span>
<span id="L442"><span class="lineNum"> 442</span> <span class="tlaUNC"> 0 : if (kDebugMode || TestConfig.instance.isVerboseLogging) {</span></span>
<span id="L443"><span class="lineNum"> 443</span> <span class="tlaGNC"> 30 : debugPrint('EventBus: dispose 시작');</span></span>
<span id="L444"><span class="lineNum"> 444</span> <span class="tlaGNC"> 15 : await _logInstanceState();</span></span>
<span id="L445"><span class="lineNum"> 445</span> : }</span>
<span id="L446"><span class="lineNum"> 446</span> : </span>
<span id="L447"><span class="lineNum"> 447</span> <span class="tlaGNC"> 15 : _isDisposed = true;</span></span>
<span id="L448"><span class="lineNum"> 448</span> <span class="tlaGNC"> 30 : if (!_streamController.isClosed) {</span></span>
<span id="L449"><span class="lineNum"> 449</span> : try {</span>
<span id="L450"><span class="lineNum"> 450</span> <span class="tlaGNC"> 30 : await _streamController.close();</span></span>
<span id="L451"><span class="lineNum"> 451</span> : </span>
<span id="L452"><span class="lineNum"> 452</span> : // 마이크로태스크 실행으로 비동기 작업 완료 보장</span>
<span id="L453"><span class="lineNum"> 453</span> <span class="tlaGNC"> 30 : await Future.microtask(() {});</span></span>
<span id="L454"><span class="lineNum"> 454</span> : </span>
<span id="L455"><span class="lineNum"> 455</span> <span class="tlaGNC"> 15 : if ((kDebugMode || TestConfig.instance.isVerboseLogging) &amp;&amp; TestUtils.isInTest) {</span></span>
<span id="L456"><span class="lineNum"> 456</span> <span class="tlaGNC"> 21 : debugPrint('EventBus: 인스턴스 dispose 완료 (테스트 ID: $_currentTestId)');</span></span>
<span id="L457"><span class="lineNum"> 457</span> : // dispose 후 상태 로깅</span>
<span id="L458"><span class="lineNum"> 458</span> <span class="tlaGNC"> 7 : await _logInstanceState();</span></span>
<span id="L459"><span class="lineNum"> 459</span> : }</span>
<span id="L460"><span class="lineNum"> 460</span> : } catch (e) {</span>
<span id="L461"><span class="lineNum"> 461</span> <span class="tlaUNC"> 0 : if (kDebugMode || TestConfig.instance.isVerboseLogging) {</span></span>
<span id="L462"><span class="lineNum"> 462</span> <span class="tlaUNC"> 0 : debugPrint('EventBus: dispose 중 오류 - $e');</span></span>
<span id="L463"><span class="lineNum"> 463</span> : }</span>
<span id="L464"><span class="lineNum"> 464</span> : }</span>
<span id="L465"><span class="lineNum"> 465</span> : }</span>
<span id="L466"><span class="lineNum"> 466</span> <span class="tlaUNC"> 0 : } else if (kDebugMode || TestConfig.instance.isVerboseLogging) {</span></span>
<span id="L467"><span class="lineNum"> 467</span> <span class="tlaUNC"> 0 : debugPrint('EventBus: 이미 dispose된 인스턴스에 dispose 호출됨');</span></span>
<span id="L468"><span class="lineNum"> 468</span> : }</span>
<span id="L469"><span class="lineNum"> 469</span> : }</span>
<span id="L470"><span class="lineNum"> 470</span> : </span>
<span id="L471"><span class="lineNum"> 471</span> : /// 테스트 환경에서 EventBus를 초기화하는 메서드</span>
<span id="L472"><span class="lineNum"> 472</span> : /// 기존 StreamController를 닫고 새로운 것으로 교체</span>
<span id="L473"><span class="lineNum"> 473</span> <span class="tlaGNC"> 9 : Future&lt;void&gt; reset() async {</span></span>
<span id="L474"><span class="lineNum"> 474</span> <span class="tlaUNC"> 0 : if (kDebugMode || TestConfig.instance.isVerboseLogging) {</span></span>
<span id="L475"><span class="lineNum"> 475</span> <span class="tlaGNC"> 18 : debugPrint('EventBus: reset 시작');</span></span>
<span id="L476"><span class="lineNum"> 476</span> <span class="tlaGNC"> 9 : await _logInstanceState();</span></span>
<span id="L477"><span class="lineNum"> 477</span> : }</span>
<span id="L478"><span class="lineNum"> 478</span> : </span>
<span id="L479"><span class="lineNum"> 479</span> <span class="tlaGNC"> 9 : if (!_isDisposed) {</span></span>
<span id="L480"><span class="lineNum"> 480</span> : try {</span>
<span id="L481"><span class="lineNum"> 481</span> <span class="tlaGNC"> 8 : await dispose();</span></span>
<span id="L482"><span class="lineNum"> 482</span> : } catch (e) {</span>
<span id="L483"><span class="lineNum"> 483</span> : if (kDebugMode) {</span>
<span id="L484"><span class="lineNum"> 484</span> <span class="tlaUNC"> 0 : debugPrint('EventBus: reset 중 dispose 호출 오류 - $e');</span></span>
<span id="L485"><span class="lineNum"> 485</span> : }</span>
<span id="L486"><span class="lineNum"> 486</span> : }</span>
<span id="L487"><span class="lineNum"> 487</span> : }</span>
<span id="L488"><span class="lineNum"> 488</span> : </span>
<span id="L489"><span class="lineNum"> 489</span> : // 새로운 StreamController 생성</span>
<span id="L490"><span class="lineNum"> 490</span> <span class="tlaGNC"> 18 : _streamController = StreamController.broadcast();</span></span>
<span id="L491"><span class="lineNum"> 491</span> <span class="tlaGNC"> 9 : _isDisposed = false;</span></span>
<span id="L492"><span class="lineNum"> 492</span> : </span>
<span id="L493"><span class="lineNum"> 493</span> : // 활성 구독 수 초기화 (인스턴스 레벨)</span>
<span id="L494"><span class="lineNum"> 494</span> <span class="tlaGNC"> 9 : if (TestUtils.isInTest) {</span></span>
<span id="L495"><span class="lineNum"> 495</span> : _activeSubscriptionCount = 0;</span>
<span id="L496"><span class="lineNum"> 496</span> : }</span>
<span id="L497"><span class="lineNum"> 497</span> : </span>
<span id="L498"><span class="lineNum"> 498</span> : // 마이크로태스크 실행으로 비동기 작업 완료 보장</span>
<span id="L499"><span class="lineNum"> 499</span> <span class="tlaGNC"> 18 : await Future.microtask(() {});</span></span>
<span id="L500"><span class="lineNum"> 500</span> : </span>
<span id="L501"><span class="lineNum"> 501</span> <span class="tlaUNC"> 0 : if (kDebugMode || TestConfig.instance.isVerboseLogging) {</span></span>
<span id="L502"><span class="lineNum"> 502</span> <span class="tlaGNC"> 27 : debugPrint('EventBus: 인스턴스 reset 완료 (테스트 ID: $_currentTestId)');</span></span>
<span id="L503"><span class="lineNum"> 503</span> <span class="tlaGNC"> 9 : await _logInstanceState();</span></span>
<span id="L504"><span class="lineNum"> 504</span> : }</span>
<span id="L505"><span class="lineNum"> 505</span> : }</span>
<span id="L506"><span class="lineNum"> 506</span> : }</span>
</pre>
</td>
</tr>
</table>
<br>
<table width="100%" border=0 cellspacing=0 cellpadding=0>
<tr><td class="ruler"><img src="../../glass.png" width=3 height=3 alt=""></td></tr>
<tr><td class="versionInfo">Generated by: <a href="https://github.com//linux-test-project/lcov" target="_parent">LCOV version 2.3.1-1</a></td></tr>
</table>
<br>
</body>
</html>
Reference in New Issue View Git Blame Copy Permalink