@@ -210,103 +210,45 @@ def test_github_issue_55():
210210 assert result == expect
211211
212212 # supplied input
213- test = ('''pre.. import org.slf4j.Logger;
214- import org.slf4j.LoggerFactory;
215- import ru.onyma.job.Context;
216- import ru.onyma.job.RescheduleTask;
217-
218- import java.util.concurrent.ScheduledExecutorService;
219- import java.util.concurrent.TimeUnit;
220-
221- /**
222- * @author ustits
223- */
224- public abstract class MainService<T> extends RescheduleTask implements Context<T> {
225-
226- private static final Logger log = LoggerFactory.getLogger(MainService.class);
227- private final ScheduledExecutorService scheduler;
228-
229- private boolean isFirstRun = true;
230- private T configs;
231-
232- public MainService(final ScheduledExecutorService scheduler) {
233- super(scheduler);
234- this.scheduler = scheduler;
235- }
236-
237- @Override
238- public void setConfig(final T configs) {
239- this.configs = configs;
240- if (isFirstRun) {
241- scheduler.schedule(this, 0, TimeUnit.SECONDS);
242- isFirstRun = false;
243- }
244- }
245-
246- @Override
247- public void stop() {
248- super.stop();
249- scheduler.shutdown();
250- try {
251- scheduler.awaitTermination(Long.MAX_VALUE, TimeUnit.DAYS);
252- } catch (InterruptedException ie) {
253- log.warn("Unable to wait for syncs termination", ie);
254- Thread.currentThread().interrupt();
255- }
256- }
257-
258- protected final T getConfigs() {
259- return configs;
260- }
261- }''' )
213+ test = ('pre.. import org.slf4j.Logger;\n import org.slf4j.LoggerFactory;'
214+ '\n import ru.onyma.job.Context;\n import ru.onyma.job.'
215+ 'RescheduleTask;\n \n import java.util.concurrent.'
216+ 'ScheduledExecutorService;\n import java.util.concurrent.TimeUnit;'
217+ '\n \n /**\n * @author ustits\n */\n public abstract class '
218+ 'MainService<T> extends RescheduleTask implements Context<T> {\n \n '
219+ 'private static final Logger log = LoggerFactory.getLogger('
220+ 'MainService.class);\n private final ScheduledExecutorService '
221+ 'scheduler;\n \n private boolean isFirstRun = true;\n private T '
222+ 'configs;\n \n public MainService(final ScheduledExecutorService '
223+ 'scheduler) {\n super(scheduler);\n this.scheduler = scheduler;\n }\n '
224+ '\n @Override\n public void setConfig(final T configs) {\n this.'
225+ 'configs = configs;\n if (isFirstRun) {\n scheduler.schedule(this, '
226+ '0, TimeUnit.SECONDS);\n isFirstRun = false;\n }\n }\n \n @Override\n '
227+ 'public void stop() {\n super.stop();\n scheduler.shutdown();\n try {'
228+ '\n scheduler.awaitTermination(Long.MAX_VALUE, TimeUnit.DAYS);\n } '
229+ 'catch (InterruptedException ie) {\n log.warn("Unable to wait for '
230+ 'syncs termination", ie);\n Thread.currentThread().interrupt();\n }'
231+ '\n }\n \n protected final T getConfigs() {\n return configs;\n }\n }' )
262232 result = textile .textile (test )
263- expect = ('''<pre>import org.slf4j.Logger;
264- import org.slf4j.LoggerFactory;
265- import ru.onyma.job.Context;
266- import ru.onyma.job.RescheduleTask;
267-
268- import java.util.concurrent.ScheduledExecutorService;
269- import java.util.concurrent.TimeUnit;
270-
271- /**
272- * @author ustits
273- */
274- public abstract class MainService<T> extends RescheduleTask implements Context<T> {
275-
276- private static final Logger log = LoggerFactory.getLogger(MainService.class);
277- private final ScheduledExecutorService scheduler;
278-
279- private boolean isFirstRun = true;
280- private T configs;
281-
282- public MainService(final ScheduledExecutorService scheduler) {
283- super(scheduler);
284- this.scheduler = scheduler;
285- }
286-
287- @Override
288- public void setConfig(final T configs) {
289- this.configs = configs;
290- if (isFirstRun) {
291- scheduler.schedule(this, 0, TimeUnit.SECONDS);
292- isFirstRun = false;
293- }
294- }
295-
296- @Override
297- public void stop() {
298- super.stop();
299- scheduler.shutdown();
300- try {
301- scheduler.awaitTermination(Long.MAX_VALUE, TimeUnit.DAYS);
302- } catch (InterruptedException ie) {
303- log.warn("Unable to wait for syncs termination", ie);
304- Thread.currentThread().interrupt();
305- }
306- }
307-
308- protected final T getConfigs() {
309- return configs;
310- }
311- }</pre>''' )
233+ expect = ('<pre>import org.slf4j.Logger;\n import org.slf4j.LoggerFactory;'
234+ '\n import ru.onyma.job.Context;\n import ru.onyma.job.'
235+ 'RescheduleTask;\n \n import java.util.concurrent.'
236+ 'ScheduledExecutorService;\n import java.util.concurrent.'
237+ 'TimeUnit;\n \n /**\n * @author ustits\n */\n public abstract class '
238+ 'MainService<T> extends RescheduleTask implements '
239+ 'Context<T> {\n \n private static final Logger log = '
240+ 'LoggerFactory.getLogger(MainService.class);\n private final '
241+ 'ScheduledExecutorService scheduler;\n \n private boolean '
242+ 'isFirstRun = true;\n private T configs;\n \n public MainService('
243+ 'final ScheduledExecutorService scheduler) {\n super(scheduler);'
244+ '\n this.scheduler = scheduler;\n }\n \n @Override\n public void '
245+ 'setConfig(final T configs) {\n this.configs = configs;\n if ('
246+ 'isFirstRun) {\n scheduler.schedule(this, 0, TimeUnit.SECONDS);'
247+ '\n isFirstRun = false;\n }\n }\n \n @Override\n public void stop() {'
248+ '\n super.stop();\n scheduler.shutdown();\n try {\n scheduler.'
249+ 'awaitTermination(Long.MAX_VALUE, TimeUnit.DAYS);\n } catch '
250+ '(InterruptedException ie) {\n log.warn("Unable to wait '
251+ 'for syncs termination", ie);\n Thread.currentThread().'
252+ 'interrupt();\n }\n }\n \n protected final T getConfigs() {\n '
253+ 'return configs;\n }\n }</pre>' )
312254 assert result == expect
0 commit comments